broadcast

type Broadcaster[T any] interface {
	// Subscribe gets Subscriber from Broadcasters pool and appends Subscriber's active channel to
	// Broadcaster's active channel slice.
	Subscribe() Subscriber[T]

	// DetachAndWrite is a shorthand for "go WriteCtx()". Possible resource leak if
	// context.Background() or any other non-cancellable context is used. Short
	DetachAndWrite(ctx context.Context, data T)
	// WriteNonBlock uses select-default statement inside so the written data can be missed by some routines.
	// To prevent it use WriteCtx.
	WriteNonBlock(T)
	// WriteBlock uses select-case<-context.Background().Done() statement inside.
	WriteBlock(T)
	// WriteCtx uses select-case<-context.Context().Done() statement inside.
	WriteCtx(context.Context, T)
}

type Subscriber[T any] interface {
	// Read from channel. Read returns closed channel if dispatched.
	Read() <-chan T
	// Dispatch removes Subscriber's active channel from Broadcaster's active channels slice, drains it and
	// puts Subscriber itself to Broadcaster's Subscribers pool.
	Dispatch()
}