web-rpc 0.0.8

Bi-directional RPC for the Web
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

mod common;

use std::{cell::RefCell, rc::Rc, time::Duration};

use futures_util::FutureExt;
use wasm_bindgen_test::*;

#[web_rpc::service]
pub trait CountSlowly {
    async fn count_slowly(&self, target: u32, interval: Duration) -> u32;
}

impl CountSlowly for RefCell<u32> {
    async fn count_slowly(&self, target: u32, interval: Duration) -> u32 {
        loop {
            if self.replace_with(|value| value.wrapping_add(1)) == target {
                break target;
            }
            gloo_timers::future::sleep(interval).await;
        }
    }
}

#[wasm_bindgen_test]
async fn abort_via_drop() {
    let counter: Rc<RefCell<u32>> = Default::default();
    let (client, _server) =
        common::connect::<CountSlowlyService<_>, CountSlowlyClient>(counter.clone()).await;
    let mut count = client.count_slowly(10, Duration::from_millis(100)).fuse();
    let mut timeout = gloo_timers::future::sleep(Duration::from_millis(250)).fuse();
    futures_util::select! {
        _ = &mut count => panic!("`count` completed"),
        _ = &mut timeout => std::mem::drop(count)
    };
    gloo_timers::future::sleep(Duration::from_millis(250)).await;
    assert_eq!(*counter.borrow(), 3);
}

#[wasm_bindgen_test]
async fn a_request_outlives_its_client() {
    let counter: Rc<RefCell<u32>> = Default::default();
    let (client, _server) =
        common::connect::<CountSlowlyService<_>, CountSlowlyClient>(counter.clone()).await;
    let pending = client.count_slowly(2, Duration::from_millis(10));
    std::mem::drop(client);
    assert_eq!(pending.await, 2);
}