on main help sign in
chore: simplify struct initialization to direct return
b7c128aChristian Rocha
internal/pubsub/broker.go+1−2
@@ -20,12 +20,11 @@ func NewBroker[T any]() *Broker[T] {
20}
20}
21
21
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,
27 }
27 }
28− return b
29}
28}
30
29
31func (b *Broker[T]) Shutdown() {
30func (b *Broker[T]) Shutdown() {