Struct bmrng::RequestSender

pub struct RequestSender<Req, Res> { /* fields omitted */ }

Send values to the associated RequestReceiver.

Implementations

impl<Req, Res> RequestSender<Req, Res>

pub async fn send(
    &self,
    request: Req
) -> Result<ResponseReceiver<Res>, SendError<Req>>

Send a request over the MPSC channel, open the response channel

Return the ResponseReceiver which can be used to wait for a response

This call waits if the request channel is full. It does not wait for a response

pub async fn send_receive(&self, request: Req) -> Result<Res, RequestError<Req>>

Send a request over the MPSC channel, wait for the response and return it

This call waits if the request channel is full, and while waiting for the response

pub fn is_closed(&self) -> bool

Checks if the channel has been closed.

Trait Implementations

impl<Req, Res> Clone for RequestSender<Req, Res>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Req: Debug, Res: Debug> Debug for RequestSender<Req, Res>

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

Formats the value using the given formatter.