fix(sdk): no more ctx.Err() in queue polling (#3425)

ovh · Oct 9, 2018 · 064bcc9 · 064bcc9
1 parent 5df9047
commit 064bcc9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/sdk/cdsclient/http_sse.go b/sdk/cdsclient/http_sse.go
@@ -76,13 +76,13 @@ func (c *client) RequestSSEGet(ctx context.Context, path string, evCh chan<- SSE
 	var currEvent *SSEvent
 	var EOF bool
 
-	for !EOF {
-		if ctx.Err() != nil {
-			break
-		}
+	go func(stop *bool) {
+		<-ctx.Done()
+		*stop = true
+	}(&EOF)
 
+	for !EOF {
 		bs, err := br.ReadBytes('\n')
-
 		if err != nil && err != io.EOF {
 			return err
 		}