@@ -20,12 +20,11 @@ func NewBroker[T any]() *Broker[T] {
22func NewBrokerWithOptions[T any](channelBufferSize, maxEvents int) *Broker[T] {
22func NewBrokerWithOptions[T any](channelBufferSize, maxEvents int) *Broker[T] {
23− b := &Broker[T]{
23+ return &Broker[T]{
24 subs: make(map[chan Event[T]]struct{}),
24 subs: make(map[chan Event[T]]struct{}),
25 done: make(chan struct{}),
25 done: make(chan struct{}),
26 maxEvents: maxEvents,
26 maxEvents: maxEvents,
31func (b *Broker[T]) Shutdown() {
30func (b *Broker[T]) Shutdown() {