Struct ya_service_bus::connection::ConnectionRef [−][src]
pub struct ConnectionRef<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static>(_);
Implementations
impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + Unpin + 'static> ConnectionRef<Transport, H>
impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + Unpin + 'static> ConnectionRef<Transport, H>
pub fn subscribe(
&self,
topic: impl Into<String>
) -> impl Future<Output = Result<(), Error>> + 'static
pub fn unsubscribe(
&self,
topic: impl Into<String>
) -> impl Future<Output = Result<(), Error>> + 'static
pub fn broadcast(
&self,
caller: impl Into<String>,
topic: impl Into<String>,
body: Vec<u8>
) -> impl Future<Output = Result<(), Error>> + 'static
pub fn call(
&self,
caller: impl Into<String>,
addr: impl Into<String>,
body: impl Into<Vec<u8>>
) -> impl Future<Output = Result<Vec<u8>, Error>>
Trait Implementations
impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static> Clone for ConnectionRef<Transport, H>
impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static> Clone for ConnectionRef<Transport, H>
impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static> Unpin for ConnectionRef<Transport, H>
Auto Trait Implementations
impl<Transport, H> !RefUnwindSafe for ConnectionRef<Transport, H>
impl<Transport, H> Send for ConnectionRef<Transport, H>
impl<Transport, H> Sync for ConnectionRef<Transport, H>
impl<Transport, H> !UnwindSafe for ConnectionRef<Transport, H>
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V