f Moar indents

Author: tnull

lightning-background-processor/src/lib.rs

@@ -485,20 +485,17 @@ use core::task;
 /// ```
 /// # struct MyPersister {}
 /// # impl lightning::util::persist::KVStorePersister for MyPersister {
-/// # fn persist<W: lightning::util::ser::Writeable>(&self, key: &str, object: &W) -> lightning::io::Result<()> {
-/// # Ok(())
-/// # }
-/// #
+/// #     fn persist<W: lightning::util::ser::Writeable>(&self, key: &str, object: &W) -> lightning::io::Result<()> { Ok(()) }
 /// # }
 /// # struct MyEventHandler {}
 /// # impl MyEventHandler {
-/// # async fn handle_event(&self, _: lightning::events::Event) {}
+/// #     async fn handle_event(&self, _: lightning::events::Event) {}
 /// # }
 /// # #[derive(Eq, PartialEq, Clone, Hash)]
 /// # struct MySocketDescriptor {}
 /// # impl lightning::ln::peer_handler::SocketDescriptor for MySocketDescriptor {
-/// # fn send_data(&mut self, _data: &[u8], _resume_read: bool) -> usize { 0 }
-/// # fn disconnect_socket(&mut self) {}
+/// #     fn send_data(&mut self, _data: &[u8], _resume_read: bool) -> usize { 0 }
+/// #     fn disconnect_socket(&mut self) {}
 /// # }
 /// # use std::sync::{Arc, Mutex};
 /// # use std::sync::atomic::{AtomicBool, Ordering};
@@ -517,7 +514,6 @@ use core::task;
 /// # type MyScorer = Mutex<lightning::routing::scoring::ProbabilisticScorer<Arc<MyNetworkGraph>, Arc<MyLogger>>>;
 ///
 /// # fn setup_background_processing(my_persister: Arc<MyPersister>, my_event_handler: Arc<MyEventHandler>, my_chain_monitor: Arc<MyChainMonitor>, my_channel_manager: Arc<MyChannelManager>, my_gossip_sync: Arc<MyGossipSync>, my_logger: Arc<MyLogger>, my_scorer: Arc<MyScorer>, my_peer_manager: Arc<MyPeerManager>) {
-///		let stop_background_processing = Arc::new(AtomicBool::new(false));
 ///		let background_persister = Arc::clone(&my_persister);
 ///		let background_event_handler = Arc::clone(&my_event_handler);
 ///		let background_chain_mon = Arc::clone(&my_chain_monitor);
@@ -528,10 +524,11 @@ use core::task;
 ///		let background_scorer = Arc::clone(&my_scorer);
 ///
 ///		// Setup the sleeper.
-///		let should_stop = AtomicBool::new(false);
+///		let stop_background_processing = Arc::new(AtomicBool::new(false));
+///		let stop_fut = Arc::clone(&stop_background_processing);
 ///
 ///		let sleeper = move |d| {
-///			let stop = Arc::clone(&stop_background_processing);
+///			let stop = Arc::clone(&stop_fut);
 ///			Box::pin(async move {
 ///				if stop.load(Ordering::Acquire) {
 ///					true
@@ -562,7 +559,7 @@ use core::task;
 ///		});
 ///
 ///		// Stop the background processing.
-///		should_stop.store(true, Ordering::Relaxed);
+///		stop_background_processing.store(true, Ordering::Relaxed);
 ///		# }
 ///```
 #[cfg(feature = "futures")]