Struct HttpStreamAfterHeaders 

pub struct HttpStreamAfterHeaders(pub Pin<Box<dyn Stream<Item = Result<DataOrTrailers>> + Send + 'static>>);

Stream of DATA or HEADERS frames after initial HEADERS.

Technically this class is just a simple wrapper over boxed Stream of DataOrTrailers objects.

Most users won’t need anything except data, so this type provides convenient constructors and accessors.

Tuple Fields

0: Pin<Box<dyn Stream<Item = Result<DataOrTrailers>> + Send + 'static>>

Implementations

impl HttpStreamAfterHeaders

pub fn new<S>(s: S) -> HttpStreamAfterHeaders

where S: Stream<Item = Result<DataOrTrailers>> + Send + 'static,

Box and wraper futures stream of DataOrTrailers.

pub fn empty() -> HttpStreamAfterHeaders

Create an empty response stream (no body, no trailers).

pub fn bytes<S>(bytes: S) -> HttpStreamAfterHeaders

where S: Stream<Item = Result<Bytes>> + Send + 'static,

Create a response from a stream of bytes.

pub fn once(part: DataOrHeaders) -> HttpStreamAfterHeaders

pub fn once_bytes<B>(bytes: B) -> HttpStreamAfterHeaders

where B: Into<Bytes>,

Create simple response stream from bytes.

Useful when bytes are available and length is small.

If bytes object is large, it will be split into multiple frames.

pub fn filter_data(self) -> impl Stream<Item = Result<Bytes>> + Send

Take only DATA frames from the stream

pub fn catch_unwind(self) -> HttpStreamAfterHeaders

Wrap a stream with catch_unwind combinator. Transform panic into error::Error

Trait Implementations

impl Stream for HttpStreamAfterHeaders

type Item = Result<DataOrTrailers, Error>

Values yielded by the stream.

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