Trait ntex::http::body::MessageBody

pub trait MessageBody {
    fn size(&self) -> BodySize;
    fn poll_next_chunk(
        &mut self, 
        cx: &mut Context
    ) -> Poll<Option<Result<Bytes, Box<dyn Error>>>>;
}

Type that provides this trait can be streamed to a peer.

Required methods

fn size(&self) -> BodySize

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

Loading content...

Implementations on Foreign Types

impl MessageBody for ()

fn size(&self) -> BodySize

fn poll_next_chunk(
    &mut self,
    _: &mut Context
) -> Poll<Option<Result<Bytes, Box<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, Box<dyn Error>>>>

impl MessageBody for Bytes

fn size(&self) -> BodySize

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

impl MessageBody for BytesMut

fn size(&self) -> BodySize

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

impl MessageBody for &'static str

fn size(&self) -> BodySize

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

impl MessageBody for &'static [u8]

fn size(&self) -> BodySize

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

impl MessageBody for Vec<u8>

fn size(&self) -> BodySize

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

impl MessageBody for String

fn size(&self) -> BodySize

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

Loading content...

Implementors

impl MessageBody for Body

fn size(&self) -> BodySize

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

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

fn size(&self) -> BodySize

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

impl<B: MessageBody> MessageBody for Encoder<B>

fn size(&self) -> BodySize

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

impl<S> MessageBody for SizedStream<S> where
    S: Stream<Item = Result<Bytes, Box<dyn Error>>> + Unpin, 

fn size(&self) -> BodySize

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

Attempts to pull out the next value of the underlying Stream.

Empty values are skipped to prevent SizedStream's transmission being ended on a zero-length chunk, but rather proceed until the underlying Stream ends.

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

fn size(&self) -> BodySize

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

Attempts to pull out the next value of the underlying Stream.

Empty values are skipped to prevent BodyStream's transmission being ended on a zero-length chunk, but rather proceed until the underlying Stream ends.

Loading content...