use response writer's Write instead of io.Copy

prysmaticlabs · Oct 16, 2024 · 71fb9d1 · 71fb9d1
1 parent 3fa6d3b
commit 71fb9d1
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/beacon-chain/rpc/eth/events/events.go b/beacon-chain/rpc/eth/events/events.go
@@ -312,7 +312,12 @@ func (es *eventStreamer) outboxWriteLoop(ctx context.Context, cancel context.Can
 func (es *eventStreamer) writeOutbox(ctx context.Context, w StreamingResponseWriter, first lazyReader) error {
 	needKeepAlive := true
 	if first != nil {
-		if _, err := io.Copy(w, first()); err != nil {
+		b, err := io.ReadAll(first())
+		if err != nil {
+			return err
+		}
+		_, err = w.Write(b)
+		if err != nil {
 			return err
 		}
 		needKeepAlive = false