async fn wait_until_enabled(&mut self) -> Result<(), watch::error::RecvError> {
        let mut sync_status = self.sync_status.clone();
        let tip_future = sync_status.wait_until_close_to_tip();
        let debug_future = self.wait_until_enabled_by_debug();

        pin_mut!(tip_future);
        pin_mut!(debug_future);

        let (result, _unready_future) = future::select(tip_future, debug_future)
            .await
            .factor_first();

        result
    }
/// Waits until the mempool crawler is enabled.
///
/// Returns an error if communication with the syncer or state is lost.
Waits until the mempool crawler is enabled.
Returns an error if communication with the syncer or state is lost.
Waits until the mempool crawler is enabled . Returns an error if communication with the syncer or state is lost .
async fn wait_until_enabled(&mut self) -> Result<(), watch::error::RecvError> {
        let mut sync_status = self.sync_status.clone();
        let tip_future = sync_status.wait_until_close_to_tip();
        let debug_future = self.wait_until_enabled_by_debug();
        pin_mut!(tip_future);
        pin_mut!(debug_future);
        let (result, _unready_future) = future::select(tip_future, debug_future)
            .await
            .factor_first();
        result
    }
async fn wait_until_enabled ( & mut self ) -> Result < ( ) , watch :: error :: RecvError > { let mut sync_status = self . sync_status . clone ( ) ; let tip_future = sync_status . wait_until_close_to_tip ( ) ; let debug_future = self . wait_until_enabled_by_debug ( ) ; pin_mut ! ( tip_future ) ; pin_mut ! ( debug_future ) ; let ( result , _unready_future ) = future :: select ( tip_future , debug_future ) . await . factor_first ( ) ; result }
Waits until the mempool crawler is enabled.
Waits until the mempool crawler is enabled .
&mut self