Enum ResponseBody 

pub enum ResponseBody<B> {
    Body(B),
    Other(Body),
}

Response body preserving either a concrete body type or a type-erased body.

Variants

Body(B)

The original concrete body.

Other(Body)

A type-erased body.

Implementations

impl ResponseBody<Body>

pub fn into_body<B>(self) -> ResponseBody<B>

Converts a type-erased response body to another concrete response type.

impl<B> ResponseBody<B>

pub fn new(body: B) -> ResponseBody<B>

Creates a response body from a concrete body value.

pub fn take_body(&mut self) -> ResponseBody<B>

Replaces this response body with Body::None and returns the original.

impl<B> ResponseBody<B>

where B: MessageBody,

pub fn as_ref(&self) -> Option<&B>

Returns the concrete body, if this is ResponseBody::Body.

Trait Implementations

impl<B> Debug for ResponseBody<B>

where B: Debug,

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

Formats the value using the given formatter.

impl<B> From<Body> for ResponseBody<B>

fn from(b: Body) -> ResponseBody<B>

Converts to this type from the input type.

impl From<ResponseBody<Body>> for Body

fn from(b: ResponseBody<Body>) -> Body

Converts to this type from the input type.

impl<B> MessageBody for ResponseBody<B>

where B: MessageBody,

fn size(&self) -> BodySize

Returns the body size hint.

fn poll_next_chunk( &mut self, cx: &mut Context<'_>, ) -> Poll<Option<Result<Bytes, Rc<dyn Error>>>>

Polls the next body chunk.

impl<B> Stream for ResponseBody<B>

where B: MessageBody + Unpin,

type Item = Result<Bytes, Rc<dyn Error>>

Values yielded by the stream.

fn poll_next( self: Pin<&mut ResponseBody<B>>, cx: &mut Context<'_>, ) -> Poll<Option<<ResponseBody<B> as Stream>::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.