fix(sdk): http sse EOF (#3446)

ovh · Oct 11, 2018 · 45c3c5f · 45c3c5f
1 parent 826e713
commit 45c3c5f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/sdk/cdsclient/http_sse.go b/sdk/cdsclient/http_sse.go
@@ -91,6 +91,10 @@ func (c *client) RequestSSEGet(ctx context.Context, path string, evCh chan<- SSE
 			return err
 		}
 
+		if err == io.EOF {
+			EOF = true
+		}
+
 		if len(bs) < 2 {
 			continue
 		}
@@ -109,9 +113,7 @@ func (c *client) RequestSSEGet(ctx context.Context, path string, evCh chan<- SSE
 			currEvent.Data = bytes.NewBuffer(bytes.TrimSpace(spl[1]))
 			evCh <- *currEvent
 		}
-		if err == io.EOF {
-			EOF = true
-		}
+
 	}
 
 	return nil