async_ach-watch 0.1.4

Async Atomic Channel
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

use async_ach_watch::Watch;
use core::future::Future;
use core::pin::Pin;
use core::task::Poll;
use futures_test::task;

#[test]
fn test() {
    static WATCH: Watch<usize, 2> = Watch::new(0);
    let mut cx = task::noop_context();

    let mut sub1 = WATCH.subscribe();
    let mut get1 = Box::pin(sub1.changed());
    assert!(Pin::new(&mut get1).poll(&mut cx).is_pending());
    assert!(Pin::new(&mut get1).poll(&mut cx).is_pending());
    WATCH.try_send(1).unwrap();
    assert_eq!(Pin::new(&mut get1).poll(&mut cx), Poll::Ready(1));

    let mut sub2 = WATCH.subscribe();
    let mut sub3 = WATCH.subscribe();
    let mut get2 = Box::pin(sub2.changed());
    WATCH.try_send(2).unwrap();
    let mut get3 = Box::pin(sub3.changed());
    assert_eq!(Pin::new(&mut get2).poll(&mut cx), Poll::Ready(2));
    assert_eq!(Pin::new(&mut get3).poll(&mut cx), Poll::Ready(2));
}