Struct Receiver 

pub struct Receiver<E> { /* private fields */ }

Buffered stream of byte chunks

Payload stores chunks in a vector. Chunks can be received with .read() method.

Implementations

impl<E> Receiver<E>

pub fn max_size(&self, size: usize)

Set max stream size

By default max buffer size is set to 32Kb

pub fn put(&self, data: Bytes)

Put unused data back to stream

pub async fn read(&self) -> Option<Result<Bytes, E>>

Read next available bytes chunk

pub fn poll_read(&self, cx: &mut Context<'_>) -> Poll<Option<Result<Bytes, E>>>

Trait Implementations

impl<E: Debug> Debug for Receiver<E>

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

Formats the value using the given formatter.

impl<E> Stream for Receiver<E>

type Item = Result<Bytes, E>

Values yielded by the stream.

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

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.