concurrency

package

v0.0.10 Latest Latest Go to latest Published: Nov 29, 2022 License: MIT Imports: 1 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Broker[ChannelT comparable, MsgT any] struct {
	// contains filtered or unexported fields
}

Broker is a message broadcaster to multiple subscribers (channels).

func NewBroker[ChannelT comparable, MsgT any]() *Broker[ChannelT, MsgT]

NewBroker creates a new Broker.

func (b *Broker[ChannelT, MsgT]) Close()

Close stops the broker.

func (b *Broker[ChannelT, MsgT]) Publish(channel ChannelT, msg MsgT)

Publish publishes a message to the broker.

func (b *Broker[ChannelT, MsgT]) Start()

Start starts the broker.

func (b *Broker[ChannelT, MsgT]) Subscribe(channel ChannelT) chan MsgT

Subscribe subscribes to the broker.

func (b *Broker[ChannelT, MsgT]) Unsubscribe(channel ChannelT, msgCh chan MsgT)

Unsubscribe unsubscribes from the broker.