Struct http_body::collect::Collect

pub struct Collect<T>where
    T: Body,{
    body: T,
    collected: Option<Collected<T::Data>>,
    is_data_done: bool,
}

Future that resolves into a Collected.

Fields

body: T

collected: Option<Collected<T::Data>>

is_data_done: bool

Implementations

impl<T: Body> Collect<T>

pub(crate) fn new(body: T) -> Self

Trait Implementations

impl<T: Body> Future for Collect<T>

type Output = Result<Collected<<T as Body>::Data>, <T as Body>::Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'__pin, T> Unpin for Collect<T>where __Origin<'__pin, T>: Unpin, T: Body,