pinned 0.1.0

Synchronisation primitives for !Send tasks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::cell::Cell;
use std::task::Poll;

use futures::future::poll_fn;

/// Skip one round of execution.
pub(crate) async fn yield_now() {
    let yielded = Cell::new(false);

    poll_fn(move |cx| {
        if yielded.get() {
            return Poll::Ready(());
        }

        yielded.set(true);

        cx.waker().wake_by_ref();
        Poll::Pending
    })
    .await;
}