X-Git-Url: http://git.bitcoin.ninja/index.cgi?p=ldk-sample;a=blobdiff_plain;f=src%2Fmain.rs;h=bf0e24e9051ed6e8d75568f589d0da9fbd3f5570;hp=33e5eb5733d30c151bb97adf1260709d593f1b57;hb=db795e9f0c4ae10704ad14fce2986825b9f2aa59;hpb=01b091b07c04c125713392674740ac5d3ca3fa58 diff --git a/src/main.rs b/src/main.rs index 33e5eb5..bf0e24e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -482,13 +482,13 @@ async fn start_ldk() { let event_notifier = event_ntfn_sender.clone(); let listening_port = args.ldk_peer_listening_port; tokio::spawn(async move { - let listener = std::net::TcpListener::bind(format!("0.0.0.0:{}", listening_port)).unwrap(); + let listener = tokio::net::TcpListener::bind(format!("0.0.0.0:{}", listening_port)).await.unwrap(); loop { let peer_mgr = peer_manager_connection_handler.clone(); let notifier = event_notifier.clone(); - let tcp_stream = listener.accept().unwrap().0; + let tcp_stream = listener.accept().await.unwrap().0; tokio::spawn(async move { - lightning_net_tokio::setup_inbound(peer_mgr.clone(), notifier.clone(), tcp_stream) + lightning_net_tokio::setup_inbound(peer_mgr.clone(), notifier.clone(), tcp_stream.into_std().unwrap()) .await; }); }