X-Git-Url: http://git.bitcoin.ninja/index.cgi?p=ldk-sample;a=blobdiff_plain;f=src%2Fmain.rs;h=653ad8e9fa90b10c0790d451d7251153a1c95a7d;hp=bf0e24e9051ed6e8d75568f589d0da9fbd3f5570;hb=fdd4a78ee3b6198b9a4e48ea8e8464f53baa716e;hpb=bb94f28a1faa695ff5f0f66c05811a7cb739c101 diff --git a/src/main.rs b/src/main.rs index bf0e24e..653ad8e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -482,14 +482,19 @@ 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 = tokio::net::TcpListener::bind(format!("0.0.0.0:{}", listening_port)).await.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().await.unwrap().0; tokio::spawn(async move { - lightning_net_tokio::setup_inbound(peer_mgr.clone(), notifier.clone(), tcp_stream.into_std().unwrap()) - .await; + lightning_net_tokio::setup_inbound( + peer_mgr.clone(), + notifier.clone(), + tcp_stream.into_std().unwrap(), + ) + .await; }); } });