Fix breaking tests

egnyte · Apr 18, 2018 · e08797d · e08797d
1 parent a612fe8
commit e08797d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/backend/stream/client.go b/pkg/backend/stream/client.go
@@ -45,11 +45,13 @@ func (client *Client) Query(ctx context.Context, q common.Query) <-chan common.L
 	reader := bufio.NewReader(client.reader)
 	go func() {
 		var ltFunc heuristic.LogTimestampParser
+	LFor:
 		for {
 			select {
 			case <-ctx.Done():
 				// Context canceled, let's get outta here
-				break
+				break LFor
+			default:
 			}
 			line, err := reader.ReadString('\n')
 			if err != nil {