Struct GrpcServerStream 

pub struct GrpcServerStream<S, T>
where
    S: Stream<Item = Result<T, GrpcStatus>> + Send + 'static,
    T: Message + Send + 'static,
{
    pub stream: S,
    pub initial_metadata: HeaderMap,
}

Available on crate feature grpc only.

Server-streaming gRPC response.

Encodes each Ok item with the standard length-prefix framing and emits a final HTTP/2 trailer carrying grpc-status (Ok if the stream terminates cleanly) and grpc-message when applicable.

Fields

stream: S

initial_metadata: HeaderMap

Server metadata sent as response headers (initial metadata).

Implementations

impl<S, T> GrpcServerStream<S, T>

where S: Stream<Item = Result<T, GrpcStatus>> + Send + 'static, T: Message + Send + 'static,

pub fn new(stream: S) -> GrpcServerStream<S, T>

pub fn with_metadata(self, headers: HeaderMap) -> GrpcServerStream<S, T>

Trait Implementations

impl<S, T> Responder for GrpcServerStream<S, T>

where S: Stream<Item = Result<T, GrpcStatus>> + Send + 'static, T: Message + Send + 'static,

fn into_response(self) -> Response<TakoBody>

Converts the implementing type into an HTTP response.