Struct hyper::body::Body

pub struct Body {
    kind: Kind,
    extra: Option<Box<Extra>>,
}

A stream of Bytes, used when receiving bodies.

A good default HttpBody to use in many applications.

Note: To read the full body, use body::to_bytes or body::aggregate.

Fields

kind: Kind

extra: Option<Box<Extra>>

Keep the extra bits in an Option<Box<Extra>>, so that Body stays small in the common case (no extras needed).

Implementations

impl Body

pub fn empty() -> Body

Create an empty Body stream.

Example

use hyper::{Body, Request};

// create a `GET /` request
let get = Request::new(Body::empty());

pub fn channel() -> (Sender, Body)

Create a Body stream with an associated sender half.

Useful when wanting to stream chunks from another thread.

pub(crate) fn new_channel( content_length: DecodedLength, wanter: bool, ) -> (Sender, Body)

pub fn wrap_stream<S, O, E>(stream: S) -> Body

where S: Stream<Item = Result<O, E>> + Send + 'static, O: Into<Bytes> + 'static, E: Into<Box<dyn StdError + Send + Sync>> + 'static,

Wrap a futures Stream in a box inside Body.

Example

let chunks: Vec<Result<_, std::io::Error>> = vec![
    Ok("hello"),
    Ok(" "),
    Ok("world"),
];

let stream = futures_util::stream::iter(chunks);

let body = Body::wrap_stream(stream);

Optional

This function requires enabling the stream feature in your Cargo.toml.

fn new(kind: Kind) -> Body

pub(crate) fn h2( recv: RecvStream, content_length: DecodedLength, ping: Recorder, ) -> Self

pub(crate) fn delayed_eof(&mut self, fut: Receiver<Infallible>)

fn take_delayed_eof(&mut self) -> Option<DelayEof>

fn extra_mut(&mut self) -> &mut Extra

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

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

pub(super) fn take_full_data(&mut self) -> Option<Bytes>

Trait Implementations

impl Body for Body

type Data = Bytes

Values yielded by the Body.

type Error = Error

The error type this Body might generate.

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

Attempt to pull out the next data buffer of this stream.

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

Poll for an optional single HeaderMap of trailers.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

fn data(&mut self) -> Data<'_, Self>

where Self: Sized + Unpin,

Returns future that resolves to next data chunk, if any.

fn trailers(&mut self) -> Trailers<'_, Self>

where Self: Sized + Unpin,

Returns future that resolves to trailers, if any.

fn map_data<F, B>(self, f: F) -> MapData<Self, F>

where Self: Sized, F: FnMut(Self::Data) -> B, B: Buf,

Maps this body’s data value to a different value.

fn map_err<F, E>(self, f: F) -> MapErr<Self, F>

where Self: Sized, F: FnMut(Self::Error) -> E,

Maps this body’s error value to a different value.

fn collect(self) -> Collect<Self>

where Self: Sized,

Turn this body into Collected body which will collect all the DATA frames and trailers.

fn boxed(self) -> BoxBody<Self::Data, Self::Error>

where Self: Sized + Send + Sync + 'static,

Turn this body into a boxed trait object.

fn boxed_unsync(self) -> UnsyncBoxBody<Self::Data, Self::Error>

where Self: Sized + Send + 'static,

Turn this body into a boxed trait object that is !Sync.

impl Debug for Body

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

Formats the value using the given formatter.

impl Default for Body

fn default() -> Body

Returns Body::empty().

impl From<&'static [u8]> for Body

fn from(slice: &'static [u8]) -> Body

Converts to this type from the input type.

impl From<&'static str> for Body

fn from(slice: &'static str) -> Body

Converts to this type from the input type.

impl From<Box<dyn Stream<Item = Result<Bytes, Box<dyn Error + Sync + Send>>> + Send>> for Body

Optional

This function requires enabling the stream feature in your Cargo.toml.

fn from( stream: Box<dyn Stream<Item = Result<Bytes, Box<dyn StdError + Send + Sync>>> + Send>, ) -> Body

Converts to this type from the input type.

impl From<Bytes> for Body

fn from(chunk: Bytes) -> Body

Converts to this type from the input type.

impl From<Cow<'static, [u8]>> for Body

fn from(cow: Cow<'static, [u8]>) -> Body

Converts to this type from the input type.

impl From<Cow<'static, str>> for Body

fn from(cow: Cow<'static, str>) -> Body

Converts to this type from the input type.

impl From<String> for Body

fn from(s: String) -> Body

Converts to this type from the input type.

impl From<Vec<u8>> for Body

fn from(vec: Vec<u8>) -> Body

Converts to this type from the input type.

impl Stream for Body

Optional

This function requires enabling the stream feature in your Cargo.toml.

type Item = Result<Bytes, Error>

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.