Enum Payload 

pub enum Payload {
    None,
    H1(Payload),
    H2(Payload),
    Stream(PayloadStream),
}

Type represent streaming payload

Variants

None

H1(Payload)

H2(Payload)

Stream(PayloadStream)

Implementations

impl Payload

pub fn take(&mut self) -> Self

Takes current payload and replaces it with None value

pub fn from_stream<S>(stream: S) -> Self

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

Create payload from stream

pub async fn recv(&mut self) -> Option<Result<Bytes, PayloadError>>

Attempt to pull out the next value of this payload.

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

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

Trait Implementations

impl Debug for Payload

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

Formats the value using the given formatter.

impl Default for Payload

fn default() -> Payload

Returns the “default value” for a type.

impl From<Payload> for Payload

fn from(v: Payload) -> Self

Converts to this type from the input type.

impl From<Pin<Box<dyn Stream<Item = Result<Bytes, PayloadError>>>>> for Payload

fn from(pl: PayloadStream) -> Self

Converts to this type from the input type.

impl From<Receiver<PayloadError>> for Payload

fn from(v: Payload) -> Self

Converts to this type from the input type.

impl Stream for Payload

type Item = Result<Bytes, PayloadError>

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.