Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub async fn connect(subscriber: &Subscriber, path: Path) -> Result<Connection>

Connect to the channel at the the specified path. The channel may either be a listener, or a singleton.

pub fn is_dead(&self) -> bool

return true if the connection is dead

pub fn start_batch(&self) -> Batch

start a new batch of messages

pub fn send(&self, batch: Batch) -> Result<()>

send a batch of messages

pub fn send_one<S: Pack>(&self, t: &S) -> Result<()>

send just one message

pub fn dirty(&self) -> bool

return true if messages have been sent but not flushed. Flush is only required for pushback.

pub async fn flush(&self) -> Result<()>

Wait for sent messages to flush to the OS

pub async fn recv<R: Pack + 'static, F: FnMut(R) -> bool>( &self, f: F, ) -> Result<()>

Receive all avaliable messages, waiting for at least one message to arrive before returning. Each message will be passed to f, if f returns false, then processing the batch will be halted and any remaining messages will stay in the channel.

pub async fn try_recv<R: Pack + 'static, F: FnMut(R) -> bool>( &self, f: F, ) -> Result<()>

Receive all available messages, but do not wait for at least 1 message to arrive. If no messages are available return immediatly. This will only block if a concurrent receive is in progress.

pub async fn recv_one<R: Pack + 'static>(&self) -> Result<R>

Receive one message, waiting for at least one message to arrive if none are queued.

pub async fn try_recv_one<R: Pack + 'static>(&self) -> Result<Option<R>>

Receive a message if one is available, otherwise return Ok(None).