diff --git a/zrpc/src/peer.rs b/zrpc/src/peer.rs
index 9b1728b19517143434ded9077272ab4f4cdf8d73..251ffb5bb512e2a603b57922b9097edbd408fecc 100644
--- a/zrpc/src/peer.rs
+++ b/zrpc/src/peer.rs
@@ -115,7 +115,7 @@ impl Peer {
         let connection_state = ConnectionState {
             outgoing_tx,
             next_message_id: Default::default(),
-            response_channels: Default::default(),
+            response_channels: Arc::new(Mutex::new(Some(Default::default()))),
         };
         let mut writer = MessageStream::new(connection.tx);
         let mut reader = MessageStream::new(connection.rx);