From 71fb9d1ab6d708af215f0a7f9ced52bb230d18e0 Mon Sep 17 00:00:00 2001 From: Kasey Kirkham Date: Wed, 16 Oct 2024 10:45:12 -0500 Subject: [PATCH] use response writer's Write instead of io.Copy --- beacon-chain/rpc/eth/events/events.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/beacon-chain/rpc/eth/events/events.go b/beacon-chain/rpc/eth/events/events.go index 28e31fc9840..b5909da015f 100644 --- 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