Fix deadlock in events service

Signed-off-by: Kenfe-Mickael Laventure <mickael.laventure@gmail.com>
2017-07-20 14:56:00 +02:00
parent 5ea5fbdfc5
commit e3fcde6934
1 changed files with 2 additions and 0 deletions
--- a/events/emitter.go
+++ b/events/emitter.go
@@ -47,7 +47,9 @@ func (e *Emitter) Events(ctx context.Context, clientID string) chan *events.Enve
 			ns: ns,
 		}
 		e.sinks[clientID] = s
+		e.m.Unlock()
 		e.broadcaster.Add(s)
+		return s.ch
 	}
 	ch := e.sinks[clientID].ch
 	e.m.Unlock()