Trait tower_grpc::generic::server::ServerStreamingService

pub trait ServerStreamingService<R> {
    type Response;
    type ResponseStream: Stream<Item = Self::Response, Error = Status>;
    type Future: Future<Item = Response<Self::ResponseStream>, Error = Status>;
    fn call(&mut self, request: Request<R>) -> Self::Future;
}

A specialization of tower_service::Service.

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

Associated Types

type Response

Protobuf response message type

type ResponseStream: Stream<Item = Self::Response, Error = Status>

Stream of outbound response messages

type Future: Future<Item = Response<Self::ResponseStream>, Error = Status>

Response future

Loading content...

Required methods

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

Call the service

Loading content...

Implementors

impl<T, M, S> ServerStreamingService<M> for T where
    T: Service<Request<M>, Response = Response<S>, Error = Status>,
    S: Stream<Error = Status>, 

type Response = S::Item

type ResponseStream = S

type Future = T::Future

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

Loading content...