notify

Documentation

Index

• type Notifier
  • func NewNotifier() *Notifier
  • func (n *Notifier) Notify()
  • func (n *Notifier) Receive() <-chan struct{}

Types

type Notifier

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

Notifier is a thread safe struct that can be used to send notification about some event to multiple consumers.

func NewNotifier

func NewNotifier() *Notifier

NewNotifier returns new notifier

func (*Notifier) Notify

func (n *Notifier) Notify()

Notify closes the channel passed to consumers and creates new channel to used for next notification.

func (*Notifier) Receive

func (n *Notifier) Receive() <-chan struct{}

Receive returns channel that can be used to wait for notification. Consumers will be informed by closing the channel.