Add buffer to broker SendMessage
This commit is contained in:
parent
08dbf44529
commit
8f2fe6f9fa
|
@ -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),
|
||||
|
|
Loading…
Reference in New Issue