bus

type Bus interface {
	// Connect establishes a connection.
	Connect() Connection
	// Close closes all connections, and cleans up all bus resources. It blocks
	// until all event processing from events sent prior to Close() completes.
	Close()
}

type Connection interface {
	// Output returns a channel on which bus events can be read.
	Output() <-chan any
	// Omnicast sends the provided value to all connections to the bus including
	// the connection used to send the value. Messages sent
	// while the connection is closed or closing will be discarded.
	Omnicast(any)
	// OmnicastSync is a synchronous Omnicast that returns whether the send was
	// successful.
	OmnicastSync(any) bool
	// Broadcast sends the provided value to all connections to the bus other than
	// the connection used to send the value. Messages sent
	// while the connection is closed or closing will be discarded.
	Broadcast(any)
	// BroadcastSync is a synchronous Broadcast that returns whether the send was
	// successful.
	BroadcastSync(any) bool
	// Loopback sends the provided value to the output channel of only the connection
	// it is called upon. Messages sent
	// while the connection is closed or closing will be discarded.
	Loopback(any)
	// LoopbackSync is a synchronous Loopback that returns whether the send was
	// successful.
	LoopbackSync(any) bool
	// Close initiates closing this connection. The connection is not fully closed until
	// the channel returned by Output closes. Proper use requires reading all remaining
	// events until the channel closes.
	Close()
}