pub const fn resolve_futures_state<Queue, Fut, Next>(
queue: &mut Queue,
subgraph_waker: Option<Waker>,
next: Next,
) -> ResolveFutures<Next, &mut Queue, Queue>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.