Merge pull request #3 from mjgarton/allowExitWhenCallerDoesntConsume

Allow timeout to complete
2016-09-29 08:00:07 +01:00
parent ab413e42fe bf498197cb
commit 4725bf05ee
1 changed files with 2 additions and 0 deletions
--- a/client.go
+++ b/client.go
@@ -335,6 +335,8 @@ func (c *client) query(params *QueryParam) error {
 				inp.sent = true
 				select {
 				case params.Entries <- inp:
+				case <-finish:
+					return nil
 				}
 			} else {
 				// Fire off a node specific query