Struct HttpBody 

pub struct HttpBody { /* private fields */ }

The streaming body returned by HttpTransporter.

We implement oio::ReadStream for HttpBody. Services can use HttpBody as Service::Reader.

Implementations

impl HttpBody

pub fn new<S>(stream: S, size: Option<u64>) -> Self

where S: Stream<Item = Result<Buffer>> + Send + Sync + Unpin + 'static,

Available on non-WebAssembly only.

Create a new HttpBody with given stream and optional size.

pub fn map_inner( self, f: impl FnOnce(Box<dyn Stream<Item = Result<Buffer>> + Send + Sync + Unpin + 'static>) -> Box<dyn Stream<Item = Result<Buffer>> + Send + Sync + Unpin + 'static>, ) -> Self

Available on non-WebAssembly only.

Map the inner stream.

pub async fn to_buffer(&mut self) -> Result<Buffer>

Read all data from the stream.

Trait Implementations

impl ReadStream for HttpBody

async fn read(&mut self) -> Result<Buffer>

Read the next data chunk from the stream.

fn read_all(&mut self) -> impl Future<Output = Result<Buffer>> + MaybeSend

Read all data from the reader.

impl Send for HttpBody

Safety

HttpBody is Send on non-wasm targets.

impl Sync for HttpBody

Safety

HttpBody is Sync on non-wasm targets.