Skip to main content

BidiHandler

Type Alias BidiHandler 

Source
pub type BidiHandler = Arc<dyn Fn(Value, RpcContext, UnboundedReceiver<Result<Value, RpcError>>, UnboundedSender<Result<Value, RpcError>>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync>;
Expand description

Bidi-streaming handler. Receives an inbound receiver and an outbound sender; drives both independently. Returns when the handler is done emitting (the runtime wires the sender to RpcStream frames).

Aliased Typeยง

pub struct BidiHandler { /* private fields */ }