Struct PooledConn 

pub struct PooledConn {
    pub slot_id: u32,
    pub session_id: String,
    pub loop_id: Mutex<String>,
    pub workspace_id: String,
    pub client: Client,
    pub event_rx: Mutex<Option<Receiver<Value>>>,
    pub reader_live: AtomicBool,
    pub last_used: Mutex<Instant>,
    /* private fields */
}

One connection slot in the pool.

Fields

slot_id: u32

Internal slot id.

session_id: String

Application session id (app_key in Go).

loop_id: Mutex<String>

Bound StrangeLoop id.

workspace_id: String

Workspace id used at bootstrap.

client: Client

Underlying protocol client.

event_rx: Mutex<Option<Receiver<Value>>>

Forwarded event stream (ReceiveMessages → mpsc); None until start_reader.

reader_live: AtomicBool

Whether the forwarder task is still running.

last_used: Mutex<Instant>

Last time this slot was acquired.

Implementations

impl PooledConn

pub async fn get_loop_id(&self) -> String

Loop id (Go getLoopID).

pub async fn is_connected(&self) -> bool

Whether the underlying client is connected and has not signalled disconnect.

pub async fn event_stream_live(&self) -> bool

Whether ReceiveMessages is still feeding event_rx.