Trait MessageBody 

pub trait MessageBody: 'static {
    // Required methods
    fn size(&self) -> BodySize;
    fn poll_next_chunk(
        &mut self,
        cx: &mut Context<'_>,
    ) -> Poll<Option<Result<Bytes, Rc<dyn Error>>>>;
}

Interface for types that can be streamed to a peer.

Required Methods

fn size(&self) -> BodySize

Message body size hind

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

Implementations on Foreign Types

impl MessageBody for &'static str

fn size(&self) -> BodySize

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

impl MessageBody for &'static [u8]

fn size(&self) -> BodySize

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

impl MessageBody for ()

fn size(&self) -> BodySize

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

impl MessageBody for String

fn size(&self) -> BodySize

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

impl MessageBody for Vec<u8>

fn size(&self) -> BodySize

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

impl MessageBody for Bytes

fn size(&self) -> BodySize

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

impl MessageBody for BytesMut

fn size(&self) -> BodySize

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

impl<T: MessageBody> MessageBody for Box<T>

fn size(&self) -> BodySize

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

Implementors

impl MessageBody for Body

impl<B: MessageBody> MessageBody for ResponseBody<B>

impl<S> MessageBody for BoxedBodyStream<S>

where S: Stream<Item = Result<Bytes, Rc<dyn Error>>> + Unpin + 'static,

impl<S> MessageBody for SizedStream<S>

where S: Stream<Item = Result<Bytes, Rc<dyn Error>>> + Unpin + 'static,

impl<S, E> MessageBody for BodyStream<S, E>

where S: Stream<Item = Result<Bytes, E>> + Unpin + 'static, E: Error + 'static,