moirai-executor 0.9.1

Hybrid executor implementation for Moirai concurrency library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! `AsyncFutureState` as its own `Waker`.

use std::{future::Future, sync::Arc, task::Wake};

use super::future_state::AsyncFutureState;
use crate::{registry::StateLease, schedule::WorkSubmit};

impl<S, F, L> Wake for AsyncFutureState<S, F, L>
where
    S: WorkSubmit,
    F: Future + Send + 'static,
    F::Output: Send + 'static,
    L: StateLease,
{
    fn wake(self: Arc<Self>) {
        self.schedule_wake();
    }

    fn wake_by_ref(self: &Arc<Self>) {
        self.schedule_wake();
    }
}