Struct ssp_server::device_handle::PushEventReceiver

pub struct PushEventReceiver(pub Receiver<Event>);

Receiver end of the device-sent event queue.

Owner of the receiver can regularly attempt to pop events from the queue, and decide how to handle an returned event(s).

Example:

let stop_polling = Arc::new(AtomicBool::new(false));
let poll_mode = ssp_server::PollMode::Interactive;

let mut handle = ssp_server::DeviceHandle::new("/dev/ttyUSB0")?;

let rx: ssp_server::PushEventReceiver = handle.start_background_polling_with_queue(
    Arc::clone(&stop_polling),
    poll_mode,
)?;

// Pop events from the queue
loop {
    while let Ok(event) = rx.pop_event() {
        log::debug!("Received an event: {event}");
        // do stuff in response to the event...
    }
}

Tuple Fields

0: Receiver<Event>

Implementations

impl PushEventReceiver

pub fn new(queue: Receiver<Event>) -> Self

Creates a new PushEventReceiver from the provided queue.

pub fn pop_event(&self) -> Result<Event>

Attempt to pop an event from the queue.

Returns Err(_) if an event could not be retrieved before the timeout.