x-bow 0.2.0

Precise State Management Library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use core::{pin::Pin, task::Context};

use async_ui_internal_utils::dummy_waker::dummy_waker;
use futures_core::Stream;

pub fn is_ready(s: Pin<&mut dyn Stream<Item = ()>>) -> bool {
    let waker = dummy_waker();
    let mut ctx = Context::from_waker(&waker);
    s.poll_next(&mut ctx).is_ready()
}

pub fn is_all_pending<const N: usize>(s: [Pin<&mut dyn Stream<Item = ()>>; N]) -> bool {
    s.into_iter().all(|one| !is_ready(one))
}

pub fn is_all_ready<const N: usize>(s: [Pin<&mut dyn Stream<Item = ()>>; N]) -> bool {
    s.into_iter().all(|one| is_ready(one))
}