Struct futures_util::stream::stream::flatten_unordered::WrappedWaker

struct WrappedWaker {
    inner_waker: UnsafeCell<Option<Waker>>,
    poll_state: SharedPollState,
    need_to_poll: u8,
}

Will update state with the provided value on wake_by_ref call and then, if there is a need, call inner_waker.

Fields

inner_waker: UnsafeCell<Option<Waker>>

poll_state: SharedPollState

need_to_poll: u8

Implementations

impl WrappedWaker

unsafe fn replace_waker(self_arc: &mut Arc<Self>, cx: &Context<'_>)

Replaces given waker’s inner_waker for polling stream/futures which will update poll state on wake_by_ref call. Use only if you need several contexts.

Safety

This function will modify waker’s inner_waker via UnsafeCell, so it should be used only during POLLING phase by one thread at the time.

fn start_waking( &self ) -> Option<(u8, PollStateBomb<'_, impl FnOnce(&SharedPollState) -> u8>)>

Attempts to start the waking process for the waker with the given value. If succeeded, then the stream isn’t yet woken and not being polled at the moment.

Trait Implementations

impl ArcWake for WrappedWaker

fn wake_by_ref(self_arc: &Arc<Self>)

Indicates that the associated task is ready to make progress and should be polled.

fn wake(self: Arc<Self, Global>)

Indicates that the associated task is ready to make progress and should be polled.

impl Send for WrappedWaker

impl Sync for WrappedWaker