bevy_defer 0.17.0

A simple asynchronous runtime for executing async coroutines.
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

//! A `!Send` internally mutable list of [`Waker`]s.
use std::{
    cell::RefCell,
    task::{Context, Waker},
};

/// A `!Send` internally mutable list of [`Waker`]s.
#[derive(Debug, Default)]
pub struct WaitList(RefCell<Vec<Waker>>);

#[allow(unused)]
impl WaitList {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn len(&self) -> usize {
        self.0.borrow().len()
    }

    pub fn is_empty(&self) -> bool {
        self.0.borrow().is_empty()
    }

    /// Register a [`Waker`].
    pub fn push(&self, waker: Waker) {
        self.0.borrow_mut().push(waker)
    }

    /// Register a [`Waker`] in [`Context`].
    pub fn push_cx(&self, cx: &Context) {
        self.0.borrow_mut().push(cx.waker().clone())
    }

    /// Wake all [`Waker`]s registered.
    pub fn wake(&self) {
        self.0.borrow_mut().drain(..).for_each(|w| w.wake())
    }
}