Struct Connection

pub struct Connection<Resume: Session> { /* private fields */ }

A client’s handle to an active suspended connection. Use resume to enter the server’s event loop and continue interaction.

Must not be dropped. Specify the resumption protocol to handle disconnecting.

Implementations

impl<Resume: Session> Connection<Resume>

pub fn resume(self) -> Resume

Resumes the connection, entering the server’s event loop. Returns the client’s side of the connection resumption protocol.

Examples found in repository

examples/chat.rs (line 166)

fn handle_user(socket: WebSocketStream<TcpStream>) -> Recv<Option<Login>> {
    let (write, read) = socket.split();
    let inbox = handle_inbox(write);
    let messages = read_socket(read);

    fork(|try_login: Send<Option<Login>>| async {
        let inbox = inbox.push(ChatLine::Info(format!("What's your name?")));
        let Queue::Item(name, messages) = messages.pop().await else {
            inbox.close1();
            return try_login.send1(None);
        };

        let Ok(accepted) = try_login.choose(Some).send(Nick(name)).recv1().await else {
            inbox
                .push(ChatLine::Error(format!("Login refused")))
                .close1();
            return messages.for_each1(|_| future::ready(())).await;
        };

        let conn = messages
            .fold1(accepted.send(inbox).recv1().await, |conn, content| async {
                conn.resume()
                    .choose(Command::Message)
                    .send(content)
                    .recv1()
                    .await
            })
            .await;

        conn.resume().send1(Command::Logout);
    })
}