check if channel is closed before continuing

topfreegames · May 21, 2018 · f02ed4d · f02ed4d
1 parent bc5ecce
commit f02ed4d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/modules/unique_session.go b/modules/unique_session.go
@@ -54,9 +54,13 @@ func NewUniqueSession(server *cluster.Server, rpcServer *cluster.NatsRPCServer,
 }
 
 func (u *UniqueSession) processBindings(bindingsChan chan *nats.Msg) {
+loop:
 	for {
 		select {
-		case s := <-bindingsChan:
+		case s, ok := <-bindingsChan:
+			if !ok {
+				break loop
+			}
 			msgData := s.Data
 			msg := &BindingMsg{}
 			err := json.Unmarshal(msgData, msg)