Struct ResponseBody 

struct ResponseBody {
    chunks: SyncStream<Result<Result<Bytes, Error>, Truncated>>,
}

The response body object_store reads: it maps the SyncStream that relays awc’s body chunks off the worker thread into http_body data frames. A Truncated relay — the worker was torn down before the body finished — becomes a retryable error, so object_store never accepts a silently short body as complete.

Fields

chunks: SyncStream<Result<Result<Bytes, Error>, Truncated>>

Trait Implementations

impl Body for ResponseBody

type Data = Bytes

Values yielded by the Body.

type Error = HttpError

The error type this Body might generate.

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

Attempt to pull out the next frame of this stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.