pub trait ServerStreamingService<R> {
    type Response;
    type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
    type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;

    fn call(&mut self, request: Request<R>) -> Self::Future;
Expand description

A specialization of tower_service::Service.

Existing tower_service::Service implementations with the correct form will automatically implement ServerStreamingService.

Required Associated Types§

Protobuf response message type

Stream of outbound response messages

Response future

Required Methods§

Call the service