socketioxide-redis 0.4.1

Redis adapter for the socket.io protocol
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

//! Check that each adapter function with a broadcast options that is [`Local`] returns an immediate future
mod fixture;

macro_rules! assert_now {
    ($fut:expr) => {
        #[allow(unused_must_use)]
        futures_util::FutureExt::now_or_never($fut)
            .expect("Returned future should be sync")
            .unwrap()
    };
}

#[tokio::test]
async fn test_local_fns() {
    let [io1, io2] = fixture::spawn_servers();

    io1.ns("/", async || ()).await.unwrap();
    io2.ns("/", async || ()).await.unwrap();

    let (_, mut rx1) = io1.new_dummy_sock("/", ()).await;
    let (_, mut rx2) = io2.new_dummy_sock("/", ()).await;

    timeout_rcv!(&mut rx1); // connect packet
    timeout_rcv!(&mut rx2); // connect packet

    assert_now!(io1.local().emit("test", "test"));
    assert_now!(io1.local().emit_with_ack::<_, ()>("test", "test"));
    assert_now!(io1.local().join("test"));
    assert_now!(io1.local().leave("test"));
    assert_now!(io1.local().disconnect());
    assert_now!(io1.local().fetch_sockets());
}