Struct bmrng::RequestReceiver

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

Receive requests values from the associated RequestSender

Instances are created by the channel function.

Implementations

impl<Req, Res> RequestReceiver<Req, Res>

pub async fn recv(&mut self) -> Result<Payload<Req, Res>, RequestError<Req>>

Receives the next value for this receiver.

pub fn close(&mut self)

Closes the receiving half of a channel without dropping it.

pub fn into_stream(self) -> impl Stream<Item = Payload<Req, Res>>

Converts this receiver into a stream

Trait Implementations

impl<Req, Res> AsMut<RequestReceiver<Req, Res>> for RequestReceiverStream<Req, Res>

fn as_mut(&mut self) -> &mut RequestReceiver<Req, Res>

Performs the conversion.

impl<Req, Res> AsRef<RequestReceiver<Req, Res>> for RequestReceiverStream<Req, Res>

fn as_ref(&self) -> &RequestReceiver<Req, Res>

Performs the conversion.

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

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

Formats the value using the given formatter.

impl<Req, Res> From<RequestReceiver<Req, Res>> for RequestReceiverStream<Req, Res>

fn from(receiver: RequestReceiver<Req, Res>) -> Self

Performs the conversion.