pub type BoxedPayloadStream = Pin<Box<dyn Stream<Item = Result<Bytes, PayloadError>>>>;
Expand description

A boxed payload stream.

Aliased Type§

struct BoxedPayloadStream { /* private fields */ }

Trait Implementations§

1.33.0 · source§

impl<P> Deref for Pin<P>where P: Deref,

§

type Target = <P as Deref>::Target

The resulting type after dereferencing.
source§

fn deref(&self) -> &<P as Deref>::Target

Dereferences the value.
source§

impl<T, B> MessageBody for Pin<T>where T: DerefMut<Target = B> + Unpin, B: MessageBody + ?Sized,

§

type Error = <B as MessageBody>::Error

The type of error that will be returned if streaming body fails. Read more
source§

fn size(&self) -> BodySize

Body size hint. Read more
source§

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

Attempt to pull out the next chunk of body bytes. Read more
source§

fn try_into_bytes(self) -> Result<Bytes, Self>where Self: Sized,

Try to convert into the complete chunk of body bytes. Read more
source§

fn boxed(self) -> BoxBodywhere Self: Sized + 'static,

Wraps this body into a BoxBody. Read more