Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

WebSocket transport for iFlow communication

This class provides a low-level WebSocket interface for communicating with iFlow. It handles connection management, message serialization, and error recovery.

Implementations

impl WebSocketTransport

pub fn new(url: String, timeout: f64) -> Self

Initialize WebSocket transport

Arguments

• url - WebSocket URL (e.g., ws://localhost:8090/acp?peer=iflow)
• timeout - Connection timeout in seconds

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

Establish WebSocket connection

Returns

• Ok(()) if the connection was successful
• Err(IFlowError) if the connection failed

pub async fn send(&mut self, message: &Value) -> Result<()>

Send a message through WebSocket

Arguments

• message - Message to send (string or JSON Value)

Returns

• Ok(()) if the message was sent successfully
• Err(IFlowError) if there was an error

pub async fn send_raw(&mut self, message: &str) -> Result<()>

Send a raw string message through WebSocket

Arguments

• message - Raw message string to send

Returns

• Ok(()) if the message was sent successfully
• Err(IFlowError) if there was an error

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

Receive messages from WebSocket

This method receives a single message from the WebSocket connection.

Returns

• Ok(String) containing the received message
• Err(IFlowError) if there was an error

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

Close WebSocket connection gracefully

pub fn is_connected(&self) -> bool

Check if the WebSocket is connected

Returns

True if connected, False otherwise

pub fn url(&self) -> &str

Get the WebSocket URL

Returns

The WebSocket URL