Struct ConnectionRef 

pub struct ConnectionRef<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static>(/* private fields */);

Implementations

impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + Unpin + 'static> ConnectionRef<Transport, H>

pub fn bind( &self, addr: impl Into<String>, ) -> impl Future<Output = Result<(), Error>> + 'static

pub fn unbind( &self, addr: impl Into<String>, ) -> impl Future<Output = Result<(), Error>> + 'static

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>>, no_reply: bool, ) -> impl Future<Output = Result<Vec<u8>, Error>>

pub fn call_streaming( &self, caller: impl Into<String>, addr: impl Into<String>, body: impl Into<Vec<u8>>, ) -> impl Stream<Item = Result<ResponseChunk, Error>>

pub fn connected(&self) -> bool

Trait Implementations

impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static> Clone for ConnectionRef<Transport, H>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Transport: Sink<GsbMessage, Error = ProtocolError> + Unpin + 'static, H: CallRequestHandler + 'static> Unpin for ConnectionRef<Transport, H>