Struct TcpConnection 

pub struct TcpConnection { /* private fields */ }

TCP connection to a snapserver.

Implementations

impl TcpConnection

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

Create a new connection to the given host and port.

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

Establish the TCP connection.

pub fn disconnect(&mut self)

Close the connection.

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

Send a message without waiting for a response.

pub async fn send_request( &mut self, msg_type: MessageType, payload: &MessagePayload, timeout: Duration, ) -> Result<TypedMessage>

Send a request and wait for the response (matched by refersTo).

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

Receive the next message. If it’s a response to a pending request, deliver it to the waiting caller and receive again.