Merge pull request #17 from TheoMcGinley/close-channel-after-error

Closed receiver chan on error
5 years ago · da4ae4693e
parent c0f3d20440 48bc14b3e0
commit da4ae4693e
1 changed files with 1 additions and 0 deletions
--- a/client.go
+++ b/client.go
@ -150,6 +150,7 @@ func (c *Client) recv(receiver chan<- interface{}) (err error) {
 	for {
 		val, err := next(c.Session.decoder)
 		if err != nil {
+			close(receiver)
 			return err
 		}
 		receiver <- val