stream-future 0.5.0

Implement an async iterator with return value.
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

#![feature(coroutines)]

use futures_util::StreamExt;
use std::{future::ready, time::Duration};
use stream_future::*;
use tokio::time::interval;

#[tokio::test]
async fn basic() {
    #[stream(i32)]
    async fn foo() -> bool {
        yield 0;
        yield 1;
        yield (ready(2).await);
        true
    }

    let gf = foo();
    tokio::pin!(gf);
    assert_eq!((&mut gf).collect::<Vec<_>>().await, [0, 1, 2]);
    assert!(gf.await);
}

#[tokio::test]
async fn stream() {
    #[stream(i32)]
    async fn foo() {
        yield 0;
        yield (ready(1).await);
        yield 2;
    }

    let gf = foo();
    tokio::pin!(gf);
    assert_eq!(gf.collect::<Vec<_>>().await, [0, 1, 2]);
}

#[tokio::test]
async fn future() {
    #[stream]
    async fn bar() -> bool {
        ready(true).await
    }

    assert!(bar().await);
}

#[tokio::test]
async fn timeout() {
    #[stream]
    async fn foo() {
        let mut timer = interval(Duration::from_micros(10));
        timer.tick().await;
        timer.tick().await;
    }

    foo().await;
}