fix(sdk): http sse ctx error (#3445)

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