1 files changed, 1 insertions, 2 deletions
diff --git a/p2p/src/connection.rs b/p2p/src/connection.rs
index c1a7a8c..f2e9d1e 100644
--- a/p2p/src/connection.rs
+++ b/p2p/src/connection.rs
@@ -74,8 +74,7 @@ impl Connection {
     pub async fn recv<P: Protocol>(&self) -> Result<ProtocolEvent> {
         match self.listeners.get(&P::id()) {
             Some(l) => l.recv().await.map_err(Error::from),
-            // TODO
-            None => todo!(),
+            None => Err(Error::UnsupportedProtocol(P::id())),
         }
     }