Trait dubbo::triple::server::service::StreamingSvc

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

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

Required Associated Types

type Response

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

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

Required Methods

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

Implementors

impl<T, S, M1, M2> StreamingSvc<M1> for Twhere
    T: Service<Request<Decoding<M1>>, Response = Response<S>, Error = Status>,
    S: Stream<Item = Result<M2, Status>>,

type Response = M2

type ResponseStream = S

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