enstream 0.3.0

Conversion from Future to Stream
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

#![feature(type_alias_impl_trait)]

use std::{future::Future, task, task::Poll};

use enstream::{enstream, HandlerFn, HandlerFnLifetime, Yielder};
use futures_util::{stream::Stream, task::noop_waker_ref};

struct YieldsInDrop<'stream> {
    yielder: Yielder<'stream, Box<u32>>,
}

impl<'stream> Drop for YieldsInDrop<'stream> {
    fn drop(&mut self) {
        let mut cx = task::Context::from_waker(noop_waker_ref());
        let mut fut = Box::pin(self.yielder.yield_item(Box::new(0)));
        assert_eq!(fut.as_mut().poll(&mut cx), Poll::Pending);
    }
}

struct Handler;
type Fut<'yielder> = impl Future<Output = ()>;
impl<'yielder> HandlerFnLifetime<'yielder, Box<u32>> for Handler {
    type Fut = Fut<'yielder>;
}
impl HandlerFn<Box<u32>> for Handler {
    fn call(
        self,
        yielder: Yielder<'_, Box<u32>>,
    ) -> <Self as HandlerFnLifetime<'_, Box<u32>>>::Fut {
        async {
            let _yields_in_drop = YieldsInDrop { yielder };
            std::future::pending().await
        }
    }
}

#[test]
fn test() {
    let mut cx = task::Context::from_waker(noop_waker_ref());

    let mut stream = Box::pin(enstream(Handler));
    assert_eq!(stream.as_mut().poll_next(&mut cx), Poll::Pending);
    drop(stream);
}