Struct wasm_rs_shared_channel::spsc::Receiver

pub struct Receiver<T>(pub SharedChannel<T>)
 where
    T: Shareable;

Receiver part of the channel

Implementations

impl<T> Receiver<T> where
    T: Shareable, 

pub fn recv(&self, timeout: Option<Duration>) -> Result<Option<T>, JsValue>

Receives a value from the channel

If timeout is None, if there is no message, it'll immediately return Ok(None).

If timeout is Some(duration) it will return Ok(Some(value)) if there was a value, otherwise, it'll return Ok(None) when timed out.

There's no way to specify an infinite timeout. Instead, a sufficiently large std::time::Duration should be used.