events

Jul 11, 2022

Changes in this version

+ func DispatchSync(event T)

+ func DispatchSyncWithTimeout(event T, timeout time.Duration)

type Dispatcher

+ DispatchSyncWithTimeout func(event T, timeout time.Duration)

type EventStream

+ SyncStream func() <-chan SyncEvent[T]

+ type SyncEvent struct

+ Event T

+ func (se *SyncEvent[T]) Done()

Jun 1, 2022

Changes in this version

+ func Dispatch(event T)

May 12, 2022

Changes in this version

type Dispatcher

+ AddFilteredEventHandler func(handler EventHandler[T], condition EventCondition[T]) HandlerID

+ NewFilteredEventStream func(condition EventCondition[T]) EventStream[T]

+ type EventCondition func(T) bool

Apr 14, 2022

Changes in this version

type Dispatcher

+ func GlobalDispatcherFor() Dispatcher[T]

+ func NewDispatcher() Dispatcher[T]

+ CloseEventStreams func()

Mar 30, 2022

Changes in this version

+ type Dispatcher interface

+ AddEventHandler func(handler EventHandler[T]) HandlerID

+ Dispatch func(event T)

+ DispatchSync func(event T)

+ NewEventStream func() EventStream[T]

+ RemoveEventHandler func(id HandlerID) bool

+ func DispatcherFor() Dispatcher[T]

+ type EventHandler func(T)

+ type EventStream interface

+ Close func()

+ IsClosed func() bool

+ Stream func() <-chan T

+ type HandlerID string