dope-runtime 0.20.0

Thread-per-core execution and process lifecycle for dope
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

use dope_core::driver::result::poll;
use turn::{modes, scope::Core};

use crate::executor::drive::turn;

#[must_use]
pub(crate) struct Polled<'turn, 'd, M> {
    core: Core<'turn, 'd, M>,
    events: poll::Drain,
    status: turn::Status,
}

impl<'turn, 'd, M> Polled<'turn, 'd, M>
where
    M: modes::Mode<'d>,
{
    pub(super) const fn new(
        core: Core<'turn, 'd, M>,
        events: poll::Drain,
        status: turn::Status,
    ) -> Self {
        Self {
            core,
            events,
            status,
        }
    }

    pub(crate) fn park(mut self) -> turn::Parked<'turn, 'd, M> {
        M::park(&mut self.core);
        turn::Parked::new(self.core, self.events, self.status)
    }
}