subscribers

type Subscriber[T any] struct {
	// contains filtered or unexported fields
}

type Subscribers[T any] interface {
	// Push adds a new subscriber
	Push(ctx context.Context, ch chan<- T)
	// SendAll sends a message to all subscribers
	SendAll(message T)
	// CleanDone removes subscribers whose context is done
	CleanDone()
}