acceptor 0.0.1

no_std bundle of thin acceptors built on the accepts core traits
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

use core::sync::atomic::{AtomicUsize, Ordering};

use accepts::{Accepts, AsyncAccepts};

use crate::support::{Recorder, block_on};

use super::{AsyncInspect, Inspect};

#[test]
fn inspect_runs_before_forwarding() {
    let recorder = Recorder::new();
    let seen = AtomicUsize::new(0);

    let inspector = Inspect::new(
        |_: &u32| {
            seen.fetch_add(1, Ordering::SeqCst);
        },
        recorder.clone(),
    );

    inspector.accept(1);
    inspector.accept(2);

    assert_eq!(seen.load(Ordering::SeqCst), 2);
    assert_eq!(recorder.take(), vec![1, 2]);
}

#[test]
fn async_inspect_runs_before_forwarding() {
    let recorder = Recorder::new();
    let seen = AtomicUsize::new(0);

    let inspector = AsyncInspect::new(
        |_: &u32| {
            let seen = &seen;
            async move {
                seen.fetch_add(1, Ordering::SeqCst);
            }
        },
        recorder.clone(),
    );

    block_on(inspector.accept_async(3));
    block_on(inspector.accept_async(4));

    assert_eq!(seen.load(Ordering::SeqCst), 2);
    assert_eq!(recorder.take(), vec![3, 4]);
}