events

Documentation

Index

• Variables
• func MakeHandler[E any]() chan E
• type Dispatcher
  • func NewDispatcher() *Dispatcher
  • func (d *Dispatcher) Dispatch(event any)
  • func (d *Dispatcher) GoString() string
  • func (d *Dispatcher) String() string
  • func (d *Dispatcher) Subscribe(handler interface{}) *Subscription
• type Done
• type Subscription
  • func (s *Subscription) Apply()
  • func (s *Subscription) Cancel()

Variables

var (
	DispatcherCapacity     = 20
	DefaultDispatchTimeout = 10 * time.Second
	HandlerCapacity        = 10
)

Functions

func MakeHandler

func MakeHandler[E any]() chan E

Types

type Dispatcher

type Dispatcher struct {
	DispatchTimeout time.Duration
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher() *Dispatcher

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(event any)

func (*Dispatcher) GoString

func (d *Dispatcher) GoString() string

func (*Dispatcher) String

func (d *Dispatcher) String() string

func (*Dispatcher) Subscribe

func (d *Dispatcher) Subscribe(handler interface{}) *Subscription

type Done

type Done <-chan struct{}

type Subscription

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

func (*Subscription) Apply

func (s *Subscription) Apply()

func (*Subscription) Cancel

func (s *Subscription) Cancel()