Trait tonic::body::Body

pub trait Body: Sealed + Send + Sync {
    type Data: Buf;
    type Error: Into<Box<dyn Error + Send + Sync>>;

    fn is_end_stream(&self) -> bool;
    fn poll_data(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>
    ) -> Poll<Option<Result<Self::Data, Self::Error>>>;
    fn poll_trailers(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>
    ) -> Poll<Result<Option<HeaderMap>, Self::Error>>;
}

A trait alias for http_body::Body.

Required Associated Types

type Data: Buf

The body data type.

type Error: Into<Box<dyn Error + Send + Sync>>

The errors produced from the body.

Required Methods

fn is_end_stream(&self) -> bool

Check if the stream is over or not.

Reference http_body::Body::is_end_stream.

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

Poll for more data from the body.

Reference http_body::Body::poll_data.

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

Poll for the trailing headers.

Reference http_body::Body::poll_trailers.

Implementors

impl<T> Body for T where
    T: HttpBody + Send + Sync + 'static,
    T::Error: Into<Box<dyn Error + Send + Sync>>, 

type Data = <T as Body>::Data

type Error = <T as Body>::Error