Struct WakeSignal 

pub struct WakeSignal { /* private fields */ }

Signal for waking the consumer when new data is available.

In production this will wrap an eventfd file descriptor. For testing without io_uring, it uses a simple atomic flag + thread parking.

Implementations

impl WakeSignal

pub fn new() -> Self

Create a new wake signal.

pub fn notify(&self)

Signal the other side that it should wake up and check the queue.

pub fn take(&self) -> bool

Check if a notification is pending and clear it. Returns true if there was a pending notification.

pub fn is_signaled(&self) -> bool

Check if a notification is pending without clearing it.

Trait Implementations

impl Default for WakeSignal

fn default() -> Self

Returns the “default value” for a type.