pub type ClientStreamHandler = Arc<dyn Fn(Value, RpcContext, UnboundedReceiver<Result<Value, RpcError>>) -> Pin<Box<dyn Future<Output = Result<Value, RpcError>> + Send>> + Send + Sync>;Expand description
Client-streaming handler. Receives the initial request plus an
UnboundedReceiver of streamed client values, returns a single
aggregated response.
Aliased Typeยง
pub struct ClientStreamHandler { /* private fields */ }