diff --git a/crates/rpc/src/proto.rs b/crates/rpc/src/proto.rs
index 28963991d122d8f3fbd9aabb7077ec40d5e33cda..88df850b371e9e62ff30503b040054d6d9d62eef 100644
--- a/crates/rpc/src/proto.rs
+++ b/crates/rpc/src/proto.rs
@@ -88,7 +88,7 @@ where
             let received_at = Instant::now();
             match bytes? {
                 WebSocketMessage::Binary(bytes) => {
-                    zstd::stream::copy_decode(bytes.as_slice(), &mut self.encoding_buffer).unwrap();
+                    zstd::stream::copy_decode(bytes.as_slice(), &mut self.encoding_buffer)?;
                     let envelope = Envelope::decode(self.encoding_buffer.as_slice())
                         .map_err(io::Error::from)?;