Skip to main content

resolve_futures_state

Function resolve_futures_state 

Source
pub const fn resolve_futures_state<Queue, Fut, Next>(
    queue: &mut Queue,
    subgraph_waker: Option<Waker>,
    next: Next,
) -> ResolveFutures<Next, &mut Queue, Queue>
where Queue: Default + Extend<Fut> + FusedStream<Item = Fut::Output> + Unpin, Fut: Future, Next: Push<Fut::Output, ()>,
Expand description

Creates a ResolveFutures push that resolves futures and sends their outputs.

The futures queue is supplied as external state.

Queue is generally expected to be either futures_util::stream::FuturesUnordered or futures_util::stream::FuturesOrdered.