Enum SnapConnection 

pub enum SnapConnection {
    Tcp(TcpConnection),
}

Unified connection over supported transports.

Variants

Tcp(TcpConnection)

Plain TCP connection.

Implementations

impl SnapConnection

pub fn new(scheme: &str, host: &str, port: u16) -> Result<Self>

Create a new connection based on the scheme.

pub async fn connect(&mut self) -> Result<()>

Establish the connection.

pub fn disconnect(&mut self)

Close the connection.

pub async fn send( &mut self, msg_type: MessageType, payload: &MessagePayload, ) -> Result<()>

Send a message.

pub async fn recv(&mut self) -> Result<TypedMessage>

Receive the next message.