events

Documentation

Overview

events defines an event subscriber and dispatcher

Index

• type EmitterInterface
• type Event
• type EventEmitter
  • func (e *EventEmitter) Emit(evt Event)
  • func (e *EventEmitter) Subscribe(ctx context.Context, handler func(Event))
  • func (e *EventEmitter) UnsubscribeAll()

Types

type EmitterInterface

type EmitterInterface interface {
	// Emit Sends an event to the subscribed listeners
	Emit(Event)

	// Subscribe Registers a callback that will receive emitted events
	Subscribe(context.Context, func(Event))

	// UnsubscribeAll removes all listeners
	UnsubscribeAll()
}

EmitterInterface Root interface for events dispatch

type Event

type Event interface{}

Event Is a base interface for events

type EventEmitter

type EventEmitter struct {
	Subscribers []*eventSubscription
	// contains filtered or unexported fields
}

EventEmitter Registers listeners and dispatches events to them

func (*EventEmitter) Emit

func (e *EventEmitter) Emit(evt Event)

func (*EventEmitter) Subscribe

func (e *EventEmitter) Subscribe(ctx context.Context, handler func(Event))

func (*EventEmitter) UnsubscribeAll

func (e *EventEmitter) UnsubscribeAll()