Struct WebsocketCommon

pub struct WebsocketCommon {
    pub events: WebsocketEventEmitter,
    /* private fields */
}

Fields

events: WebsocketEventEmitter

Implementations

impl WebsocketCommon

pub fn new( initial_pool: Vec<Arc<WebsocketConnection>>, mode: WebsocketMode, reconnect_delay: usize, agent: Option<AgentConnector>, user_agent: Option<String>, ) -> Arc<Self>

pub async fn is_connection_ready( &self, connection: &WebsocketConnection, allow_non_established: bool, ) -> bool

Checks if a WebSocket connection is ready for use.

Arguments

• connection - The WebSocket connection to check
• allow_non_established - If true, allows connections that are not fully established

Returns

true if the connection is ready, false otherwise

Behavior

A connection is considered ready if:

• It has a write channel (unless allow_non_established is true)
• No renewal is pending
• No reconnection is pending
• No close has been initiated