refactor!: remove bootstrap and reachability

maidsafe · Jan 20, 2023 · b7b4976 · b7b4976
1 parent 5b2aaac
commit b7b4976
Show file tree

Hide file tree

Showing 7 changed files with 86 additions and 465 deletions.
diff --git a/examples/p2p_node.rs b/examples/p2p_node.rs
@@ -14,7 +14,7 @@
 
 use bytes::Bytes;
 use color_eyre::eyre::Result;
-use qp2p::{Config, Endpoint};
+use qp2p::{Config, Endpoint, WireMsg};
 use std::{
     env,
     net::{Ipv4Addr, SocketAddr},
@@ -74,7 +74,7 @@ async fn main() -> Result<()> {
         let src = connection.remote_address();
 
         // loop over incoming messages
-        while let Ok(Some((_, _, bytes))) = incoming.next().await {
+        while let Ok(Some(WireMsg((_, _, bytes)))) = incoming.next().await {
             println!("Received from {:?} --> {:?}", src, bytes);
             if bytes == *MSG_MARCO {
                 let reply = Bytes::from(MSG_POLO);