Struct WebSocketMessageSender

pub struct WebSocketMessageSender { /* private fields */ }

WebSocket message sender implementation for sending messages over WebSockets

This sender enables real-time bidirectional communication between TAP nodes, providing a persistent connection that can be used for both sending and receiving messages. WebSockets are particularly useful for scenarios requiring:

• Low-latency message delivery
• Bidirectional communication
• Connection state awareness
• Reduced overhead compared to repeated HTTP requests

Connection Management

The WebSocket sender manages a pool of connections to recipient endpoints, keeping them alive and reconnecting as needed. This makes it suitable for high-frequency message exchanges between known parties.

Error Handling

The sender handles various WebSocket-specific error conditions:

• Connection failures
• Message delivery failures
• Connection drops and reconnection
• Protocol errors

Cross-platform Support

Like the HTTP sender, the WebSocket sender supports:

• Native environments (using tokio_tungstenite)
• WASM environments (using web-sys WebSocket API)
• Fallback implementations for environments without these libraries

Implementations

impl WebSocketMessageSender

pub fn new(base_url: String) -> Self

Create a new WebSocketMessageSender with the given base URL

pub fn with_options(base_url: String) -> Self

Create a new WebSocketMessageSender with custom options

Trait Implementations

impl Debug for WebSocketMessageSender

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

Formats the value using the given formatter.

impl MessageSender for WebSocketMessageSender

fn send<'life0, 'async_trait>( &'life0 self, packed_message: String, recipient_dids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a packed message to one or more recipients