Implement SSE

asians-cloud · Sep 17, 2023 · 7c4a773 · 7c4a773
1 parent 5b69b5c
commit 7c4a773
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/stream_bouncer.go b/stream_bouncer.go
@@ -221,12 +221,11 @@ func (b *StreamBouncer) RunStream(ctx context.Context) {
           log.Errorf("Response status is %d", resp.StatusCode)
         }
 
-        log.Info(resp.StatusCode)
-
 
 	for {
 		select {
 		case <-ctx.Done():
+                  close(b.Stream)
                   resp.Body.Close()
                   return
 		default: