Trait tarantool::fiber::channel::RecvTimeout

pub trait RecvTimeout<T> {
    // Required method
    fn recv_maybe_timeout(
        &self,
        timeout: Option<Duration>
    ) -> Result<T, RecvError>;

    // Provided methods
    fn recv(&self) -> Option<T> { ... }
    fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvError> { ... }
    fn try_recv(&self) -> Result<T, TryRecvError> { ... }
}

Required Methods

fn recv_maybe_timeout(&self, timeout: Option<Duration>) -> Result<T, RecvError>

Receive a message from the channel.

In case the channel was closed or the current fiber was cancelled the function returns None.

This function may perform a yield in case there is no message ready.

Provided Methods

fn recv(&self) -> Option<T>

fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvError>

fn try_recv(&self) -> Result<T, TryRecvError>

Implementors

impl<T> RecvTimeout<T> for Channel<T>