alarm

Documentation

Index

• type Alarm
  • func New() *Alarm
  • func (a *Alarm) Subscribe() Subscriber
  • func (a *Alarm) WakeUpAll()
• type Subscriber
  • func NewCombinator(a, b Subscriber) Subscriber
  • func NewTicker(interval time.Duration) Subscriber

Types

type Alarm

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

func New

func New() *Alarm

func (*Alarm) Subscribe

func (a *Alarm) Subscribe() Subscriber

func (*Alarm) WakeUpAll

func (a *Alarm) WakeUpAll()

type Subscriber

type Subscriber interface {
	C() <-chan struct{}
	io.Closer
}

func NewCombinator

func NewCombinator(a, b Subscriber) Subscriber

func NewTicker

func NewTicker(interval time.Duration) Subscriber