async-fifo 0.6.5

MPMC & oneshot channels with (a)sync API
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

use std::task::{Context, Waker, Wake, Poll};
use std::thread::{Thread, park, current};
use std::future::Future;
use std::sync::Arc;
use std::pin::pin;

fn current_thread_waker() -> Waker {
    struct ThreadWaker {
        handle: Thread,
    }

    impl Wake for ThreadWaker {
        fn wake(self: Arc<Self>) {
            self.handle.unpark();
        }
    }

    let thread_waker = ThreadWaker {
        handle: current(),
    };

    Arc::new(thread_waker).into()
}

pub fn block_on<T, F: Future<Output = T>>(fut: F) -> T {
    let waker = current_thread_waker();
    let mut context = Context::from_waker(&waker);
    let mut pinned = pin!(fut);

    loop {
        match pinned.as_mut().poll(&mut context) {
            Poll::Ready(retval) => break retval,
            Poll::Pending => park(),
        }
    }
}