pub type StreamHandler = Arc<dyn Fn(Value, RpcContext, UnboundedSender<Result<Value, RpcError>>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync>;
pub struct StreamHandler { /* private fields */ }