rings-core 0.3.0

Chord DHT implementation with ICE
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

use wasm_bindgen_futures::future_to_promise;
use wasm_bindgen_futures::spawn_local;
use wasm_bindgen_futures::JsFuture;
use wasm_bindgen_test::wasm_bindgen_test;

#[wasm_bindgen_test]
async fn test_std_channel() {
    let (sender, receiver) = std::sync::mpsc::sync_channel(1);
    async {
        sender.send("test").unwrap();
    }
    .await;
    async {
        assert_eq!(receiver.recv().unwrap(), "test");
    }
    .await;
}

// ref https://rustwasm.github.io/wasm-bindgen/api/src/wasm_bindgen_futures/lib.rs.html#NaN
#[wasm_bindgen_test]
async fn test_async_channel_via_future_to_promise() {
    let (sender, mut receiver) = futures::channel::mpsc::channel(1);
    let fut = async move {
        let mut sender = sender.clone();
        assert!(!sender.is_closed());
        sender.try_send("test").unwrap();
        Ok("ok".into())
    };
    let promise = future_to_promise(fut);
    JsFuture::from(promise).await.unwrap();
    assert_eq!(receiver.try_next().unwrap(), Some("test"));
}

// ref https://rustwasm.github.io/wasm-bindgen/api/src/wasm_bindgen_futures/lib.rs.html#77-82
#[wasm_bindgen_test]
fn test_async_channel_in_spawn_local() {
    let (sender, mut receiver) = futures::channel::mpsc::channel(1);
    spawn_local(async move {
        let mut sender = sender.clone();
        assert!(!sender.is_closed());
        sender.try_send("test").unwrap();
    });
    spawn_local(async move {
        let next = receiver.try_next().unwrap();
        assert_eq!(next, Some("test"));
    })
}