Trait tonic::server::ClientStreamingService

pub trait ClientStreamingService<R> {
    type Response;
    type Future: Future<Output = Result<Response<Self::Response>, Status>>;

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

A specialization of tower_service::Service.

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

Required Associated Types

type Response

Protobuf response message type

type Future: Future<Output = Result<Response<Self::Response>, Status>>

Response future

Required Methods

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

Call the service

Implementors

impl<T, M1, M2> ClientStreamingService<M1> for Twhere
    T: Service<Request<Streaming<M1>>, Response = Response<M2>, Error = Status>,

type Response = M2

type Future = <T as Service<Request<Streaming<M1>>>>::Future