diff --git a/beacon_node/eth2_libp2p/src/rpc/handler.rs b/beacon_node/eth2_libp2p/src/rpc/handler.rs index 93f26eed8..24201ceeb 100644 --- a/beacon_node/eth2_libp2p/src/rpc/handler.rs +++ b/beacon_node/eth2_libp2p/src/rpc/handler.rs @@ -912,6 +912,8 @@ async fn process_inbound_substream( substream_closed = true; } } + } else if matches!(item, RPCCodedResponse::StreamTermination(_)) { + // The sender closed the stream before us, ignore this. } else { // we have more items after a closed substream, report those as errors errors.push(RPCError::InternalError(