Struct bililive_core::stream::waker::WakerProxy

pub struct WakerProxy { /* fields omitted */ }

When reading the stream, a poll_ready is executed to ensure that all pending write op including heartbeat is completed. Therefore, we need to wake the task on which stream is polled in poll_ready (and poll_flush). WakerProxy is a waker dispatcher. It will dispatch a wake op to both wakers (rx & tx), such that both stream task and sink task can be waken and no starvation will occur.

Implementations

impl WakerProxy

pub fn rx(&self, waker: &Waker)

Register the read waker.

pub fn tx(&self, waker: &Waker)

Register the write waker.

Trait Implementations

impl Debug for WakerProxy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WakerProxy

fn default() -> WakerProxy

Returns the “default value” for a type.

impl Wake for WakerProxy

fn wake(self: Arc<Self>)

Wake this task.

fn wake_by_ref(self: &Arc<Self>)

Wake this task without consuming the waker.