rings-core 0.20.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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

use super::*;

#[test]
fn test_stop_source_propagates_stop_to_existing_and_cloned_tokens() {
    let source = StopSource::new();
    let first = source.token();
    let second = first.clone();

    assert!(!first.should_stop());
    assert!(!second.should_stop());
    assert!(!source.is_stop_requested());

    source.request_stop();

    assert!(first.should_stop());
    assert!(second.should_stop());
    assert!(source.is_stop_requested());
}

#[test]
fn test_cloned_stop_source_controls_the_same_lifecycle_scope() {
    let source = StopSource::new();
    let cloned_source = source.clone();
    let token = source.token();

    cloned_source.request_stop();

    assert!(token.should_stop());
    assert!(source.is_stop_requested());
}

#[test]
fn test_never_token_is_independent_from_other_sources() {
    let source = StopSource::new();
    let token = StopToken::never();

    source.request_stop();

    assert!(!token.should_stop());
}

#[cfg(not(target_family = "wasm"))]
#[tokio::test]
async fn test_stopped_wakes_existing_and_cloned_waiters() {
    let source = StopSource::new();
    let first = source.token();
    let second = first.clone();

    let waiters = tokio::spawn(async move {
        tokio::join!(first.stopped(), second.stopped());
    });
    tokio::task::yield_now().await;
    source.request_stop();

    tokio::time::timeout(std::time::Duration::from_secs(1), waiters)
        .await
        .expect("stop waiters wake before deadline")
        .expect("stop waiter task completes");
}

#[test]
fn test_stopped_observes_a_request_before_registration() {
    let source = StopSource::new();
    let token = source.token();
    source.request_stop();

    futures::executor::block_on(token.stopped());
}