Struct AsyncTcpClient

pub struct AsyncTcpClient { /* private fields */ }

Asynchronous TCP client that encapsulates the shutdown signal.

Implementations

impl AsyncTcpClient

pub fn new() -> Self

Creates a new instance of the async TCP client.

pub async fn subscribe( &self, addr: &str, subscription_request: TcpSubscriptionRequest, ) -> Result<Receiver<Event>, TcpClientError>

Subscribes to the TCP server at addr with the given subscription request. Returns a channel receiver for incoming events.

pub fn shutdown(&self)

Signals the client to shut down by sending a signal through the watch channel.