eventbus

Sep 19, 2022

Changes in this version

type SubscriptionOption

+ func WithUnsubscribeHook(unsubscribeHook func()) SubscriptionOption[T]

Jul 14, 2022

Changes in this version

+ func RelayWithMerge(ctx context.Context, source Source[T], merge SubscriptionMerger[S, T], ...)

type Subscriber

+ Channel func() <-chan T

+ type SubscriptionMerger func(into, single T) bool

+ type SubscriptionOption func(*subscriptionOptions[T])

+ func WithChannel(channel chan T) SubscriptionOption[T]

+ func WithUnboundedChannel(interval time.Duration) SubscriptionOption[T]

Jul 6, 2022

Changes in this version

+ func Relay(ctx context.Context, source Source[T], destination Source[T])

+ func RelayWithFilter(ctx context.Context, source Source[T], filter SubscriptionFilter[T, R], ...)

+ type Source interface

+ Send func(event T)

+ SubscribeUntilDone func(context.Context, Subscriber[T]) UnsubscribeFunc

+ Subscribers func() int

+ func NewSource() Source[T]

+ type Subscriber interface

+ Close func()

+ Receive func(event T)

+ type SubscriptionFilter func(event T) (result R, accept bool)

+ type UnsubscribeFunc func()

+ func Subscribe(bus Source[T]) (<-chan T, UnsubscribeFunc)

+ func SubscribeUntilDone(ctx context.Context, bus Source[T]) (<-chan T, UnsubscribeFunc)

+ func SubscribeWithFilter(bus Source[T], filter SubscriptionFilter[T, R]) (<-chan R, UnsubscribeFunc)

+ func SubscribeWithFilterUntilDone(ctx context.Context, source Source[T], filter SubscriptionFilter[T, R]) (<-chan R, UnsubscribeFunc)