@@ -23,7 +23,6 @@ func NewBrokerWithOptions[T any](channelBufferSize, maxEvents int) *Broker[T] {
23 b := &Broker[T]{
23 b := &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{}),
27 maxEvents: maxEvents,
26 maxEvents: maxEvents,