Add buffer to broker SendMessage

This commit is contained in:
Deluan 2020-11-09 19:24:27 -05:00 committed by Joe Stump
parent d8c07e2b01
commit 564198600a
No known key found for this signature in database
GPG Key ID: 29151C3EC48A0EB9

View File

@ -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),