RustStruct

Connection

Description

The read side of a stored socket, plus the means to reply to and re-key this connection. Returned by SocketManager::store. Dropping it unregisters the connection from the manager (its ConnId and every key index).

Signature

rust

pub struct Connection {
    id: ConnId,
    manager: SocketManager,
    stream: TypedStream,
    tx: mpsc::Sender<Message>,
}

Examples

Returned by `SocketManager::store`: the read side of a stored socket plus the means to reply and re-key it. `recv().await` yields the next inbound client event (`None` on close), `send(&ev).await` replies, `handle()` hands out a cloneable `SocketHandle`, and `add_key(key)` stores it under an additional key. Dropping it unregisters the connection from the manager automatically.

rust

let mut conn = sockets.store(user_id, socket);
while let Some(Ok(incoming)) = conn.recv().await {
    conn.send(&UserJoined { user_id }).await.ok();
}