Struct tonic::codec::EncodeBody

pub struct EncodeBody<T, U> { /* private fields */ }

A specialized implementation of Body for encoding Result<Bytes, Status>.

Implementations

impl<T: Encoder, U: Stream> EncodeBody<T, U>

pub fn new_client( encoder: T, source: U, compression_encoding: Option<CompressionEncoding>, max_message_size: Option<usize>, ) -> Self

Turns a stream of grpc messages into EncodeBody which is used by grpc clients for turning the messages into http frames for sending over the network.

pub fn new_server( encoder: T, source: U, compression_encoding: Option<CompressionEncoding>, compression_override: SingleMessageCompressionOverride, max_message_size: Option<usize>, ) -> Self

Turns a stream of grpc results (message or error status) into EncodeBody which is used by grpc servers for turning the messages into http frames for sending over the network.

Trait Implementations

impl<T, U> Body for EncodeBody<T, U>

where T: Encoder<Error = Status>, U: Stream<Item = Result<T::Item, Status>>,

type Data = Bytes

Values yielded by the Body.

type Error = Status

The error type this Body might generate.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

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

Attempt to pull out the next data buffer of this stream.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

impl<T: Debug, U: Debug> Debug for EncodeBody<T, U>

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

Formats the value using the given formatter.

impl<'pin, T, U> Unpin for EncodeBody<T, U>

where __EncodeBody<'pin, T, U>: Unpin,