aboutsummaryrefslogtreecommitdiff
path: root/p2p/src/connection.rs
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-07-16 08:16:57 +0200
committerhozan23 <hozan23@karyontech.net>2024-07-16 08:19:34 +0200
commitcae0c15d10235bf0ec0bd6f8b20814dc7b63dfd5 (patch)
treea0724e160cdc5c556d132b07639c0225226b761a /p2p/src/connection.rs
parent6795c2a8c8a580575d107f596961e221faad69cf (diff)
p2p: check for the endpoints before listen/connect to themHEADmaster
Diffstat (limited to 'p2p/src/connection.rs')
-rw-r--r--p2p/src/connection.rs3
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())),
}
}