|
@@ -139,7 +139,7 @@ func (s *client) eventListenersCleaner() {
|
|
|
func (s *client) registerEventListener(uuid int64) <-chan Event {
|
|
func (s *client) registerEventListener(uuid int64) <-chan Event {
|
|
|
listener := &EventListener{
|
|
listener := &EventListener{
|
|
|
uuid: uuid,
|
|
uuid: uuid,
|
|
|
- eventChan: make(chan Event),
|
|
|
|
|
|
|
+ eventChan: make(chan Event, 1),
|
|
|
}
|
|
}
|
|
|
s.locker.Lock()
|
|
s.locker.Lock()
|
|
|
s.eventListeners[uuid] = listener
|
|
s.eventListeners[uuid] = listener
|
