Skip to content

Commit

Permalink
Resolve issue introduced in pull request eclipse#470 (missing continue).
Browse files Browse the repository at this point in the history
This issue was picked up when running the tests multiple times (seemed to happen 1/10 ot the time)
  • Loading branch information
MattBrittan committed Dec 21, 2020
1 parent fbe4d12 commit 2d6fd16
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions client.go
Expand Up @@ -530,6 +530,7 @@ func (c *client) startCommsWorkers(conn net.Conn, inboundFromStore <-chan packet
if !ok {
ackOut = nil // ignore channel going forward
c.workers.Done() // matchAndDispatch has completed
continue // await next message
}
commsoboundP <- msg
case <-c.stop:
Expand Down

0 comments on commit 2d6fd16

Please sign in to comment.