Struct ya_service_bus::actix_rpc::Endpoint [−][src]
pub struct Endpoint { /* fields omitted */ }
Implementations
pub fn send<M: RpcMessage + Serialize + DeserializeOwned + Sync + Send + Unpin>(
&self,
msg: M
) -> impl Future<Output = Result<<RpcEnvelope<M> as Message>::Result, BusError>> + Unpin + 'static
pub fn send_as<M: RpcMessage + Serialize + DeserializeOwned + Sync + Send + Unpin>(
&self,
caller: impl ToString,
msg: M
) -> impl Future<Output = Result<<RpcEnvelope<M> as Message>::Result, BusError>> + Unpin + 'static
pub fn call_stream<M: RpcStreamMessage>(
&self,
msg: M
) -> impl Stream<Item = Result<Result<M::Item, M::Error>, BusError>>
Auto Trait Implementations
impl RefUnwindSafe for Endpoint
impl UnwindSafe for Endpoint