Struct TheaterConnection 

pub struct TheaterConnection {
    pub address: SocketAddr,
    /* private fields */
}

A client connection to a Theater server

This provides a thin wrapper around the TCP connection with simple send and receive methods that can be used with tokio::select!

Fields

address: SocketAddr

Server address

Implementations

impl TheaterConnection

pub fn new(address: SocketAddr) -> Self

Create a new TheaterConnection

Arguments

• address - The address of the Theater server

Returns

A new TheaterConnection instance (not yet connected)

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

Connect to the Theater server

Returns

• Ok(()) if the connection was successful
• Err(...) if there was an error connecting

pub async fn send(&mut self, command: ManagementCommand) -> Result<()>

Send a command to the server

Arguments

• command - The command to send

Returns

• Ok(()) if the command was sent successfully
• Err(...) if there was an error sending the command

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

Receive a response from the server

This method will wait for the next response from the server. It can be used with tokio::select! to handle multiple operations.

Returns

• Ok(response) if a response was received
• Err(...) if there was an error receiving the response

pub async fn send_and_receive( &mut self, command: ManagementCommand, ) -> Result<ManagementResponse>

pub fn is_connected(&self) -> bool

Check if the connection is active

Returns

• true if the connection is active
• false if the connection is not active

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

Close the connection

Returns

• Ok(()) if the connection was closed successfully
• Err(...) if there was an error closing the connection

Trait Implementations

impl Debug for TheaterConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.