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

Associated Types

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

Loading content...

Required methods

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

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

Loading content...

Implementors

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

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

Loading content...