Versions in this module Expand all Collapse all v1 v1.0.1 Jan 31, 2023 Changes in this version + const ErrBrokerIsStopped + type Broker interface + Publish func(ev Event[T]) error + Subscribe func(name string) (sub Subscription[T], err error) + Unsubscribe func(sub Subscription[T]) error + func New(ctx context.Context, qsz int) Broker[T] + type Event interface + EventType func() T + SubName func() string + type Subscription interface + ChanEv func() chan Event[T] + GetName func() string + func NewSubscription(name string, sz int) Subscription[T]
Go to main page