ovh
diff --git a/‎sdk/cdsclient/http_sse.go
Lines changed: 5 additions & 5 deletions b/‎sdk/cdsclient/http_sse.go
Lines changed: 5 additions & 5 deletions
@@ -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
 		}