chanotify

type Notifier ¶

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

Notifier can effectively notify you about receiving from particular channels. It operates with pairs <-chan struct{} <-> string which is notification channel and its identificator respectively. Notification channel is <-chan struc{}, each send to which is spawn notification from Notifier, close doesn't spawn anything and removes channel from Notifier.

func New() *Notifier

func (n *Notifier) Add(id interface{}, ch <-chan struct{}) error

func (n *Notifier) Chan() <-chan interface{}

func (n *Notifier) Close()