Skip to content

Commit

Permalink
return on loop
Browse files Browse the repository at this point in the history
  • Loading branch information
henrod committed May 21, 2018
1 parent f02ed4d commit d769bc4
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions modules/unique_session.go
Expand Up @@ -54,12 +54,11 @@ func NewUniqueSession(server *cluster.Server, rpcServer *cluster.NatsRPCServer,
}

func (u *UniqueSession) processBindings(bindingsChan chan *nats.Msg) {
loop:
for {
select {
case s, ok := <-bindingsChan:
if !ok {
break loop
return
}
msgData := s.Data
msg := &BindingMsg{}
Expand Down

0 comments on commit d769bc4

Please sign in to comment.