Struct tomsg_rs::connection::Connection

pub struct Connection { /* fields omitted */ }

A connection with a tomsg server.

Implementations

impl Connection

pub async fn connect(
    _typ: Type,
    address: impl ToSocketAddrs
) -> Result<(Self, Receiver<PushMessage>)>

Creates a new Connection with the given _typ and connects to the given address.

Returns a Result containing either an io::Error as an Error value, or a pair of a Connection and the receiver end of a mpsc channel where PushMessage instances are sent to.

pub fn send<'a, 'b>(
    &'a self,
    command: &'b Command<'b>
) -> impl Future<Output = Result<Result<Reply, CloseReason>>> + 'a

Send the given command to this Connection.

pub async fn close_reason(&self) -> Option<CloseReason>

Gets the reason this Connection is closed, or None if the Connection is still open.

pub async fn is_closed(&self) -> bool

Returns whether or not this Connection is closed.