From: Matt Corallo Date: Tue, 4 May 2021 20:07:59 +0000 (+0000) Subject: Make everything unreadable so rustfmt is happy X-Git-Url: http://git.bitcoin.ninja/?a=commitdiff_plain;h=fdd4a78ee3b6198b9a4e48ea8e8464f53baa716e;p=ldk-sample Make everything unreadable so rustfmt is happy --- diff --git a/src/cli.rs b/src/cli.rs index 04b18f9..d7a76bc 100644 --- a/src/cli.rs +++ b/src/cli.rs @@ -463,7 +463,14 @@ pub(crate) async fn connect_peer_if_necessary( return Ok(()); } } - match lightning_net_tokio::connect_outbound(Arc::clone(&peer_manager), event_notifier, pubkey, peer_addr).await { + match lightning_net_tokio::connect_outbound( + Arc::clone(&peer_manager), + event_notifier, + pubkey, + peer_addr, + ) + .await + { Some(conn_closed_fut) => { let mut closed_fut_box = Box::pin(conn_closed_fut); let mut peer_connected = false; @@ -472,7 +479,7 @@ pub(crate) async fn connect_peer_if_necessary( std::task::Poll::Ready(_) => { println!("ERROR: Peer disconnected before we finished the handshake"); return Err(()); - }, + } std::task::Poll::Pending => {} } for node_pubkey in peer_manager.get_peer_node_ids() { 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; }); } });