Enum EncapsulatedBody 

pub enum EncapsulatedBody<GrpcBody, WebBody> {
    Grpc(GrpcBody),
    Web(WebBody),
}

Type to encapsulate both inner services HttpBody types

Because poll_data(cx) and poll_trailers(cx) uses pinned reference, this enum needs to project the pin.

This enum is used as the body type in EncapsulatedFuture.

Variants

Grpc(GrpcBody)

Encapsulates the body from Grpc service

Web(WebBody)

Encapsulates the body from Web service

Trait Implementations

impl<GrpcBody, WebBody, GrpcError, WebError> Body for EncapsulatedBody<GrpcBody, WebBody>

where GrpcBody: HttpBody<Error = GrpcError>, WebBody: HttpBody<Error = WebError>, GrpcBody::Error: Into<Box<dyn Error + Send + Sync + 'static>>, WebBody::Error: Into<Box<dyn Error + Send + Sync + 'static>>, GrpcBody::Data: Into<Bytes>, WebBody::Data: Into<Bytes>,

type Data = Bytes

Values yielded by the Body.

type Error = Box<dyn Error + Sync + Send>

The error type this Body might generate.

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

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

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

Poll for an optional single HeaderMap of trailers.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

fn data(&mut self) -> Data<'_, Self>

where Self: Sized + Unpin,

Returns future that resolves to next data chunk, if any.

fn trailers(&mut self) -> Trailers<'_, Self>

where Self: Sized + Unpin,

Returns future that resolves to trailers, if any.

fn map_data<F, B>(self, f: F) -> MapData<Self, F>

where Self: Sized, F: FnMut(Self::Data) -> B, B: Buf,

Maps this body’s data value to a different value.

fn map_err<F, E>(self, f: F) -> MapErr<Self, F>

where Self: Sized, F: FnMut(Self::Error) -> E,

Maps this body’s error value to a different value.

fn collect(self) -> Collect<Self>

where Self: Sized,

Turn this body into Collected body which will collect all the DATA frames and trailers.

fn boxed(self) -> BoxBody<Self::Data, Self::Error>

where Self: Sized + Send + Sync + 'static,

Turn this body into a boxed trait object.

fn boxed_unsync(self) -> UnsyncBoxBody<Self::Data, Self::Error>

where Self: Sized + Send + 'static,

Turn this body into a boxed trait object that is !Sync.

impl<'pin, GrpcBody, WebBody> Unpin for EncapsulatedBody<GrpcBody, WebBody>

where PinnedFieldsOf<__EncapsulatedBody<'pin, GrpcBody, WebBody>>: Unpin,