Trait ya_service_bus::RpcEndpoint [−][src]
pub trait RpcEndpoint<T: RpcMessage>: Clone { type Result: Future<Output = Result<<RpcEnvelope<T> as Message>::Result, Error>>; fn send(&self, msg: T) -> Self::Result; fn send_as(&self, caller: impl ToString + 'static, msg: T) -> Self::Result; }