/// Assert that given future is pending.
///
/// This will try to poll the future a bit to ensure that it is not stuck in tokios task preemption.
Assert that given future is pending.
This will try to poll the future a bit to ensure that it is not stuck in tokios task preemption.
Assert that given future is pending . This will try to poll the future a bit to ensure that it is not stuck in tokios task preemption .
async fn assert_fut_pending<F>(fut: &mut F)
    where
        F: Future + Send + Unpin,
        F::Output: std::fmt::Debug,
    {
        tokio::select! {
            x = fut => panic!("future is not pending, yielded: {x:?}"),
            _ = tokio::time::sleep(Duration::from_millis(10)) => {},
        };
    }
async fn assert_fut_pending < F > ( fut : & mut F ) where F : Future + Send + Unpin , F :: Output : std :: fmt :: Debug , { tokio :: select ! { x fut panic ( " " ) tokio time sleep ( Duration from_millis ( 10 ) ) { } } ; }
Assert that given future is pending.
Assert that given future is pending .
fut
&mut F