sync

Documentation

Index

• type Emitter
  • func NewEmitter() *Emitter
  • func (s *Emitter) Send(msg string)
  • func (e *Emitter) Subscribe() chan string
  • func (e *Emitter) Unsubscribe(listener chan string)

Types

type Emitter

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

Emitter allows communication between multiple producers and listeners.

func NewEmitter

func NewEmitter() *Emitter

func (*Emitter) Send

func (s *Emitter) Send(msg string)

Send allows goroutines to send messages over the emitter. Non-blocking sends are ensured.

func (*Emitter) Subscribe

func (e *Emitter) Subscribe() chan string

func (*Emitter) Unsubscribe

func (e *Emitter) Unsubscribe(listener chan string)