Struct ConnectionHandle

pub struct ConnectionHandle { /* private fields */ }

Handle to a connection worker that accepts new channels as channel handles and relays messages.

Implementations

impl ConnectionHandle

pub fn protocol(&self) -> Topic

Returns the protocol that was negotiated in the client.

pub fn peer(&self) -> &PeerData

Returns the peer data structure.

pub fn initiator(&self) -> Creator

The party that initiated the underlying connection.

pub async fn open_channel( &self, topic: Topic, init_msg: Vec<u8>, flags: MsgFlags, ) -> Result<ChannelHandle, Error>

Opens a channel by queueing a command and waiting for it to be executed by the worker task.

pub async fn send_notification( &self, topic: Topic, msg: Vec<u8>, ) -> Result<(), Error>

Queues a notification to be sent.

pub fn has_event(&mut self) -> bool

Returns if there are any events in the queue. This might be an error message.

pub async fn wait_event(&mut self) -> Result<Option<WorkerEvent>, Error>

Waits for an event, asynchronously.

pub fn wait_event_blocking(&mut self) -> Result<Option<WorkerEvent>, Error>

Waits for an event, blockingly.

Trait Implementations

impl Drop for ConnectionHandle

fn drop(&mut self)

Executes the destructor for this type.