Struct ReadAsFuturesStream 

pub struct ReadAsFuturesStream<S>
where
    S: Read + Debug,
{ /* private fields */ }

Available on crate feature futures-stream only.

Adapts a Read implementation to the futures::Stream API.

Each item in the futures::Stream is a BytesView containing some bytes read from the underlying Read.

Security

This adapter is insecure if the side producing the bytes is not trusted. An attacker may trickle data byte-by-byte, consuming a large amount of resources.

Robust code working with untrusted sources should take precautions such as only processing read data when either a time or length threshold is reached and reusing buffers that have remaining capacity, appending additional data to existing buffers using read_more_into() instead of reserving new buffers for each read operation.

Implementations

impl<S> ReadAsFuturesStream<S>

where S: Read + Debug,

pub fn into_inner(self: Pin<Box<Self>>) -> S

Abandons any ongoing read operation and returns the source.

Trait Implementations

impl<S> Debug for ReadAsFuturesStream<S>

where S: Read + Debug,

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

Formats the value using the given formatter.

impl<S> Stream for ReadAsFuturesStream<S>

where S: Read + Debug,

type Item = Result<BytesView, <S as Read>::Error>

Values yielded by the stream.

fn poll_next<'a>( self: Pin<&'a mut Self>, cx: &'a 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.