diff --git a/client.go b/client.go
index d8e67ea..358d138 100644
--- a/client.go
+++ b/client.go
@@ -217,7 +217,10 @@ func (c *client) query(params *QueryParam) error {
 			}
 
 			// Check if this entry is complete
-			if inp.complete() && !inp.sent {
+			if inp.complete() {
+				if inp.sent {
+					continue
+				}
 				inp.sent = true
 				select {
 				case params.Entries <- inp: