Struct bmrng::RequestReceiverStream

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

A wrapper around RequestReceiver that implements Stream.

Implementations

impl<Req, Res> RequestReceiverStream<Req, Res>

pub fn new(recv: RequestReceiver<Req, Res>) -> Self

Create a new RequestReceiverStream.

pub fn into_inner(self) -> RequestReceiver<Req, Res>

Get back the inner Receiver.

pub fn close(&mut self)

Closes the receiving half of a channel without dropping it.

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 RequestReceiverStream<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.

impl<Req, Res> Stream for RequestReceiverStream<Req, Res>

type Item = Payload<Req, Res>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.