Skip to content

Commit

Permalink
Add buffer to broker SendMessage
Browse files Browse the repository at this point in the history
  • Loading branch information
deluan committed Nov 10, 2020
1 parent 08dbf44 commit 8f2fe6f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion server/events/sse.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ type broker struct {
func NewBroker() Broker {
// Instantiate a broker
broker := &broker{
notifier: make(chan []byte, 1),
notifier: make(chan []byte, 100),
newClients: make(chan chan []byte),
closingClients: make(chan chan []byte),
clients: make(map[chan []byte]bool),
Expand Down

0 comments on commit 8f2fe6f

Please sign in to comment.