Struct GrpcStreamResponse 

pub struct GrpcStreamResponse<T> { /* private fields */ }

Body type for gRPC responses. Yields encoded gRPC data frames and trailers.

Implementations

impl<T> ResponseBody<T>

pub fn once(msg: T) -> ResponseBody<T>

Create a response body that yields a single message then trailers.

pub fn channel() -> (ResponseSender<T>, ResponseBody<T>)

Create a response body backed by a channel for streaming multiple messages.

pub fn initial_metadata(self, headers: HeaderMap) -> ResponseBody<T>

Set initial metadata (response headers) sent alongside the response.

pub fn trailing_metadata(self, trailers: HeaderMap) -> ResponseBody<T>

Set trailing metadata merged into the final trailers frame.

These are combined with grpc-status. Trailers pushed via ResponseSender::send_trailers are appended on top.

pub fn take_initial_metadata(&mut self) -> Option<HeaderMap>

Take initial metadata headers, if set.

pub fn into_response(self, req: Request<()>) -> Response<ResponseBody<T>>

Convert self into a Response type where self is as the body. Take in the request it belongs to for potential compression header preparation.

Trait Implementations

impl<T> Body for ResponseBody<T>

where T: Message + Unpin,

type Data = Bytes

The payload data type yielded by Frame::Data variants.

type Error = ProtocolError

The error type that can occur while producing frames.

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

Attempt to pull the next frame from the body.

fn is_end_stream(&self) -> bool

Indicates whether the body has been fully consumed.

fn size_hint(&self) -> SizeHint

Returns a hint about the total size of the remaining Frame::Data payload.

impl<'r, C, B, T> Responder<WebContext<'r, C, B>> for ResponseBody<T>

where T: Message + Unpin + 'static,

type Response = Response<ResponseBody>

type Error = Error

async fn respond( self, ctx: WebContext<'r, C, B>, ) -> Result<Self::Response, Self::Error>

generate response from given request.

fn map(self, _: Self::Response) -> Result<Self::Response, Self::Error>

where Self: Sized,

map response type and mutate it’s state. default to pass through without any modification.