Struct ya_service_bus::typed::Endpoint [−][src]
pub struct Endpoint { /* fields omitted */ }
Implementations
pub fn call<T: RpcMessage + Unpin>(
&self,
msg: T
) -> impl Future<Output = Result<Result<T::Item, T::Error>, Error>> + Unpin
pub fn call_as<T: RpcMessage + Unpin>(
&self,
caller: impl ToString,
msg: T
) -> impl Future<Output = Result<Result<T::Item, T::Error>, Error>> + Unpin
pub fn call_streaming<T: RpcStreamMessage>(
&self,
msg: T
) -> impl Stream<Item = Result<Result<T::Item, T::Error>, Error>> + Unpin
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Endpoint
impl UnwindSafe for Endpoint
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V