Trait ClientStreamingHandler 

pub trait ClientStreamingHandler<Req, Res>:
    Send
    + Sync
    + 'static
where
    Req: Message + Send + 'static,
    Res: Message + Send + 'static,
{
    // Required method
    fn call(
        &self,
        ctx: Context,
        requests: BoxStream<Result<Req, ConnectError>>,
    ) -> BoxFuture<'static, Result<(Res, Context), ConnectError>>;
}

Trait for client streaming RPC handlers.

A client streaming handler receives a stream of request messages and returns a single response.

Required Methods

fn call( &self, ctx: Context, requests: BoxStream<Result<Req, ConnectError>>, ) -> BoxFuture<'static, Result<(Res, Context), ConnectError>>

Handle a client streaming RPC request.

Implementors

impl<F, Fut, Req, Res> ClientStreamingHandler<Req, Res> for FnClientStreamingHandler<F>

where F: Fn(Context, BoxStream<Result<Req, ConnectError>>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(Res, Context), ConnectError>> + Send + 'static, Req: Message + Send + 'static, Res: Message + Send + 'static,