Trait actix_web::dev::MessageBody

pub trait MessageBody {
    fn size(&self) -> BodySize;
    fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>;
}

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

Required methods

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

Loading content...

Implementations on Foreign Types

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

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for &'static [u8]

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for ()

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

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

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for &'static str

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for String

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for Vec<u8>

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

Loading content...

Implementors

impl MessageBody for Body

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for Bytes

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl MessageBody for BytesMut

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

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

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl<S> MessageBody for SizedStream<S> where
    S: Stream<Item = Bytes, Error = Error>, 

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

impl<S, E> MessageBody for BodyStream<S, E> where
    E: Into<Error>,
    S: Stream<Item = Bytes, Error = E>, 

fn size(&self) -> BodySize

fn poll_next(&mut self) -> Result<Async<Option<Bytes>>, Error>

Loading content...