Trait RpcHandler
ya_service_bus
pub trait RpcHandler<T: RpcMessage> { type Result: Future<Output = <RpcEnvelope<T> as Message>::Result> + 'static; fn handle(&mut self, caller: String, msg: T) -> Self::Result; }
type Result: Future<Output = <RpcEnvelope<T> as Message>::Result> + 'static
fn handle(&mut self, caller: String, msg: T) -> Self::Result
impl<T: RpcMessage, Output: Future<Output = Result<T::Item, T::Error>> + 'static, F: FnMut(T) -> Output + 'static> RpcHandler<T> for F
type Result = Output
fn handle(&mut self, _caller: String, msg: T) -> Self::Result