diff --git a/protocols/gossipsub/src/protocol.rs b/protocols/gossipsub/src/protocol.rs index 7f6722853c72..5ae896ac8dbf 100644 --- a/protocols/gossipsub/src/protocol.rs +++ b/protocols/gossipsub/src/protocol.rs @@ -281,7 +281,7 @@ impl Decoder for GossipsubCodec { type Error = GossipsubHandlerError; fn decode(&mut self, src: &mut BytesMut) -> Result, GossipsubHandlerError> { - let rpc = match self.codec.decode(src) { + let rpc = match self.codec.decode(src).map_err(GossipsubHandlerError::Codec) { Ok(Some(p)) => p, _ => return Ok(None), };