fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-08-01 01:11:58 +00:00
Code Issues Projects Releases Wiki Activity

refactor(examples): change ipfs-kad from async-std to tokio

Browse Source 
Related: #4449.

Pull-Request: #4590.
This commit is contained in:
Marco Inacio
2023-10-05 04:27:02 +01:00
committed by GitHub
parent 0e94bc24c7
commit 246acfd425
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
examples/ipfs-kad/src/main.rs
View File

@@ -24,9 +24,9 @@ use futures::StreamExt;
use libp2p::kad;
use libp2p::kad::record::store::MemoryStore;
use libp2p::{
development_transport, identity,
identity,
swarm::{SwarmBuilder, SwarmEvent},
PeerId,
tokio_development_transport, PeerId,
};
use std::{env, error::Error, time::Duration};
@@ -37,7 +37,7 @@ const BOOTNODES: [&str; 4] = [
"QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt",
];
#[async_std::main]
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
env_logger::init();
@@ -46,7 +46,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
let local_peer_id = PeerId::from(local_key.public());
// Set up a an encrypted DNS-enabled TCP Transport over the yamux protocol
let transport = development_transport(local_key).await?;
let transport = tokio_development_transport(local_key)?;
// Create a swarm to manage peers and events.
let mut swarm = {
@@ -63,7 +63,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
behaviour.add_address(&peer.parse()?, "/dnsaddr/bootstrap.libp2p.io".parse()?);
}
SwarmBuilder::with_async_std_executor(transport, behaviour, local_peer_id).build()
SwarmBuilder::with_tokio_executor(transport, behaviour, local_peer_id).build()
};
// Order Kademlia to search for a peer.