broadcast

type Broadcaster ¶

type Broadcaster struct {
	// contains filtered or unexported fields
}

Broadcaster is fan-out pattern for the control flow. It broadcasts a request to all subscribers and waits for their acknowledgment. It is useful for scenarios where multiple components need to be notified of an event or a change in state, and they need to acknowledge that they have received the event before proceeding. The broadcaster owns a list of channels that are used to communicate with the subscribers.

func New() *Broadcaster

func (b *Broadcaster) Cast(ctx context.Context) error

func (b *Broadcaster) Close()

func (b *Broadcaster) Register() chan chan struct{}

func (b *Broadcaster) Unregister(ch chan chan struct{})