Struct FnClientStreamingHandler 

pub struct FnClientStreamingHandler<F> { /* private fields */ }

Wrapper that implements ClientStreamingHandler for async functions.

Implementations

impl<F> FnClientStreamingHandler<F>

pub fn new(f: F) -> Self

Create a new function client streaming handler.

Trait Implementations

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

where F: Fn(RequestContext, ServiceStream<Req>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ServiceResult<B>> + Send + 'static, Req: Message + Send + 'static, Res: Message + Send + 'static, B: Encodable<Res> + Send + 'static,

type Body = B

The response body type. Typically Res.

fn call( &self, ctx: RequestContext, requests: ServiceStream<Req>, ) -> BoxFuture<'static, ServiceResult<B>>

Handle a client streaming RPC request.