notifier

Documentation

Index

• type Notifier
  • func (notifier *Notifier) Broadcast()
  • func (notifier *Notifier) C() <-chan struct{}
  • func (notifier *Notifier) Wait(ctx context.Context) error

Types

type Notifier

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

A Notifier is a synchronization primitive for waking upp all listeners at once.

func (*Notifier) Broadcast

func (notifier *Notifier) Broadcast()

Broadcast wakes all listeners if there are any.

func (*Notifier) C

func (notifier *Notifier) C() <-chan struct{}

C gets the channel that'll close on the next notification.

func (*Notifier) Wait

func (notifier *Notifier) Wait(ctx context.Context) error

Wait waits for the next `Broadcast` call, or the context's termination.