Trait madsim_tonic::server::ServerStreamingService

pub trait ServerStreamingService<R> {
    type Response;
    type ResponseStream: Stream
    where
        <Self::ResponseStream as Stream>::Item == Result<Self::Response, Status>;
    type Future: Future
    where
        <Self::Future as Future>::Output == Result<Response<Self::ResponseStream>, 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 ServerStreamingService.

Required Associated Types

type Response

Protobuf response message type

type ResponseStream: Stream
where
    <Self::ResponseStream as Stream>::Item == Result<Self::Response, Status>

Stream of outbound response messages

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

Response future

Required Methods

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

Call the service

Implementors

impl<T, S, M1, M2> ServerStreamingService<M1> for T where
    T: Service<Request<M1>, Response = Response<S>, Error = Status>,
    S: Stream<Item = Result<M2, Status>>, 

type Response = M2

type ResponseStream = S

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