Versions in this module Expand all Collapse all v1 v1.0.0 Sep 11, 2020 Changes in this version + func Connect(ctx context.Context, listener Listener, handler Handler) error + func Feed(ctx context.Context, dst Handler, src Producer) error + func Monitor(ctx context.Context, lock sync.Locker, listener Listener, producer Producer, ...) error + type Broadcast []Handler + func (b *Broadcast) Listen(ctx context.Context, h Handler) + func (b *Broadcast) Send(ctx context.Context, event interface{}) error + type Handler func(ctx context.Context, event interface{}) error + func AsHandler(ctx context.Context, f interface{}) Handler + func Buffer(ctx context.Context, handler Handler) Handler + func Drain(ctx context.Context, handler Handler) (Handler, <-chan error) + func Filter(ctx context.Context, pred Predicate, handler Handler) Handler + func FilterAny(ctx context.Context, pred interface{}, dst interface{}) Handler + type Listener func(ctx context.Context, handler Handler) + type Predicate func(ctx context.Context, event interface{}) bool + func AsPredicate(ctx context.Context, f interface{}) Predicate + type Producer func(ctx context.Context) interface + func AsProducer(ctx context.Context, f interface{}) Producer + type Source interface + Close func(ctx context.Context) + Next func(ctx context.Context) interface{} Incompatible versions in this module v2.0.0+incompatible Jul 8, 2021
Go to main page