Struct ChannelHandle

pub struct ChannelHandle { /* private fields */ }

Exclusive handle to a channel.

Implementations

impl ChannelHandle

pub fn chan_id(&self) -> u32

pub fn peer_data(&self) -> &PeerData

pub fn protocol(&self) -> Topic

pub fn topic(&self) -> Topic

pub async fn recv_msg(&mut self) -> Result<Option<InbMsg>, Error>

Receives an inbound message.

pub async fn send_payload( &mut self, payload: Vec<u8>, flags: MsgFlags, ) -> Result<(), Error>

Sends an exact payload and optionally closes the channel.

pub async fn send(&mut self, payload: Vec<u8>) -> Result<(), Error>

Sends a message.

pub async fn send_and_close(&mut self, payload: Vec<u8>) -> Result<(), Error>

Sends a message and closes the local side of the channel. New messages may still be received until the remote side closes their side too.

pub async fn close_with_err(&mut self, payload: Vec<u8>) -> Result<(), Error>

Sends an err message and close, new messages may still be received as with send_and_close.

pub async fn close(&mut self) -> Result<(), Error>

Closes the local side of the channel. New messages may still be received until the remote side closes their side too.

Trait Implementations

impl Drop for ChannelHandle

fn drop(&mut self)

Executes the destructor for this type.