rustwave 0.1.0

A lightweight async event-driven WebSocket framework for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use rustwave::{Client, Result};
use serde::Serialize;
use tokio::time::{Duration, sleep};

#[derive(Serialize)]
struct GameMessage {
    mess: String,
    room: String,
}

const ROOM: &str = "room-1";

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::connect("ws://127.0.0.1:8080/game").await?;

    client.on("online-count", |data| async move {
        println!("Online in /game: {}", data);
    });

    client.on("player-joined", |data| async move {
        println!("Someone joined the room: {}", data);
    });

    client.on("player-left", |data| async move {
        println!("Someone left the room: {}", data);
    });

    client.on("typing", |data| async move {
        println!("{}", data);
    });

    client.on("mess", |data| async move {
        println!("Room message: {}", data);
    });

    client.emit("online-count", "").await?;
    sleep(Duration::from_millis(300)).await;

    client.emit("join-room", ROOM).await?;
    sleep(Duration::from_millis(300)).await;

    client.emit("typing", ROOM).await?;
    sleep(Duration::from_millis(300)).await;

    let msg = GameMessage {
        mess: "hey room, I'm here!".to_string(),
        room: ROOM.to_string(),
    };
    client.emit("mess", msg).await?;
    sleep(Duration::from_millis(300)).await;

    client.emit("leave-room", ROOM).await?;

    sleep(Duration::from_secs(3)).await;

    Ok(())
}