Trait ya_service_bus::RpcEndpoint

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;
}

Associated Types

type Result: Future<Output = Result<<RpcEnvelope<T> as Message>::Result, Error>>

Required methods

fn send(&self, msg: T) -> Self::Result

fn send_as(&self, caller: impl ToString + 'static, msg: T) -> Self::Result

Implementors

impl<T: RpcMessage + Unpin> RpcEndpoint<T> for Endpoint where
    T: Send, 

type Result = Pin<Box<dyn Future<Output = Result<Result<T::Item, T::Error>, Error>>>>