emitter

Documentation

Index

• type Emitter
  • func New() *Emitter
  • func (e *Emitter) Emit(event Event)
  • func (e *Emitter) Subscribe(buffer int) *Subscription
• type Event
• type NewEventFunc
• type Subscription
  • func (s *Subscription) Events() <-chan Event
  • func (s *Subscription) Unsubscribe()

Types

type Emitter

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

Emitter handles event subscriptions

func New

func New() *Emitter

New creates a new Emitter

func (*Emitter) Emit

func (e *Emitter) Emit(event Event)

Emit sends new event to all subscriptions

func (*Emitter) Subscribe

func (e *Emitter) Subscribe(buffer int) *Subscription

Subscribe create a new subscription

type Event

type Event interface{}

Event type

type NewEventFunc

type NewEventFunc func(e Event)

NewEventFunc type

type Subscription

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

Subscription type

func (*Subscription) Events

func (s *Subscription) Events() <-chan Event

Listen invokes given function for each event

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe()

Unsubscribe stops getting new events