@@ -514,53 +514,53 @@ use core::task;
514
514
/// # type MyScorer = Mutex<lightning::routing::scoring::ProbabilisticScorer<Arc<MyNetworkGraph>, Arc<MyLogger>>>;
515
515
///
516
516
/// # 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>) {
517
- /// let background_persister = Arc::clone(&my_persister);
518
- /// let background_event_handler = Arc::clone(&my_event_handler);
519
- /// let background_chain_mon = Arc::clone(&my_chain_monitor);
520
- /// let background_chan_man = Arc::clone(&my_channel_manager);
521
- /// let background_gossip_sync = GossipSync::p2p(Arc::clone(&my_gossip_sync));
522
- /// let background_peer_man = Arc::clone(&my_peer_manager);
523
- /// let background_logger = Arc::clone(&my_logger);
524
- /// let background_scorer = Arc::clone(&my_scorer);
517
+ /// let background_persister = Arc::clone(&my_persister);
518
+ /// let background_event_handler = Arc::clone(&my_event_handler);
519
+ /// let background_chain_mon = Arc::clone(&my_chain_monitor);
520
+ /// let background_chan_man = Arc::clone(&my_channel_manager);
521
+ /// let background_gossip_sync = GossipSync::p2p(Arc::clone(&my_gossip_sync));
522
+ /// let background_peer_man = Arc::clone(&my_peer_manager);
523
+ /// let background_logger = Arc::clone(&my_logger);
524
+ /// let background_scorer = Arc::clone(&my_scorer);
525
525
///
526
- /// // Setup the sleeper.
527
- /// let stop_background_processing = Arc::new(AtomicBool::new(false));
528
- /// let stop_fut = Arc::clone(&stop_background_processing);
526
+ /// // Setup the sleeper.
527
+ /// let stop_background_processing = Arc::new(AtomicBool::new(false));
528
+ /// let stop_fut = Arc::clone(&stop_background_processing);
529
529
///
530
- /// let sleeper = move |d| {
531
- /// let stop = Arc::clone(&stop_fut);
532
- /// Box::pin(async move {
533
- /// if stop.load(Ordering::Acquire) {
534
- /// true
535
- /// } else {
536
- /// tokio::time::sleep(d).await;
537
- /// false
538
- /// }
539
- /// })
540
- /// };
530
+ /// let sleeper = move |d| {
531
+ /// let stop = Arc::clone(&stop_fut);
532
+ /// Box::pin(async move {
533
+ /// if stop.load(Ordering::Acquire) {
534
+ /// true
535
+ /// } else {
536
+ /// tokio::time::sleep(d).await;
537
+ /// false
538
+ /// }
539
+ /// })
540
+ /// };
541
541
///
542
- /// let mobile_interruptable_platform = false;
542
+ /// let mobile_interruptable_platform = false;
543
543
///
544
- /// tokio::spawn(async move {
545
- /// process_events_async(
546
- /// background_persister,
547
- /// |e| background_event_handler.handle_event(e),
548
- /// background_chain_mon,
549
- /// background_chan_man,
550
- /// background_gossip_sync,
551
- /// background_peer_man,
552
- /// background_logger,
553
- /// Some(background_scorer),
554
- /// sleeper,
555
- /// mobile_interruptable_platform,
556
- /// )
557
- /// .await
558
- /// .expect("Failed to process events");
559
- /// });
544
+ /// tokio::spawn(async move {
545
+ /// process_events_async(
546
+ /// background_persister,
547
+ /// |e| background_event_handler.handle_event(e),
548
+ /// background_chain_mon,
549
+ /// background_chan_man,
550
+ /// background_gossip_sync,
551
+ /// background_peer_man,
552
+ /// background_logger,
553
+ /// Some(background_scorer),
554
+ /// sleeper,
555
+ /// mobile_interruptable_platform,
556
+ /// )
557
+ /// .await
558
+ /// .expect("Failed to process events");
559
+ /// });
560
560
///
561
- /// // Stop the background processing.
562
- /// stop_background_processing.store(true, Ordering::Relaxed);
563
- /// # }
561
+ /// // Stop the background processing.
562
+ /// stop_background_processing.store(true, Ordering::Relaxed);
563
+ /// # }
564
564
///```
565
565
#[ cfg( feature = "futures" ) ]
566
566
pub async fn process_events_async <
0 commit comments