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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! This module specifies the core types for the [Fibril](https://docs.rs/fibril/) library.
//!
//! # Usage
//!
//! Please see the [the `fibril_verifier` docs](https://docs.rs/fibril_verifier/).
//!
//! # Features
//!
//! - `serde`: Implement `Serialize` and `Deserialize` where applicable.

#![cfg_attr(all(doc, CHANNEL_NIGHTLY), feature(doc_auto_cfg))]
// Support using Fibril core without the standard library.
#![cfg_attr(not(feature = "std"), no_std)]
#![deny(unused_must_use)]
#![warn(rust_2018_idioms, unreachable_pub)]

mod id;

use std::time::Duration;

#[derive(Clone, Debug, Eq, PartialEq, PartialOrd)]
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
#[non_exhaustive]
pub enum Command<M> {
    Deadline(Duration),
    DeadlineElapsed(Deadline),
    Exit,
    Expect(String),
    ExpectationMet(Expectation),
    Panic(String),
    Recv,
    Send(Id, M),
    SleepUntil(Deadline),
}

#[derive(Clone, Copy, Debug, Default, Eq, Ord, PartialEq, PartialOrd)]
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
pub struct Deadline {
    #[doc(hidden)]
    pub id: u64,
}

#[derive(Clone, Debug, Eq, PartialEq, PartialOrd)]
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
#[non_exhaustive]
pub enum Event<M> {
    DeadlineOk(Deadline),
    DeadlineElapsedOk(bool),
    ExpectOk(Expectation),
    ExpectationMetOk,
    RecvOk(Id, M),
    SendOk,
    SleepUntilOk,
    SpawnOk(Id),
}

#[derive(Clone, Debug, Eq, Ord, PartialEq, PartialOrd)]
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize))]
pub struct Expectation(String);
impl Expectation {
    pub fn new(description: String) -> Self {
        Expectation(description)
    }

    pub fn description(&self) -> &String {
        &self.0
    }
}

pub use id::Id;

pub trait Step<M> {
    fn step(&mut self, event: Event<M>) -> Command<M>;
}
impl<M, F> Step<M> for F
where
    F: FnMut(Event<M>) -> Command<M>,
{
    fn step(&mut self, event: Event<M>) -> Command<M> {
        self(event)
    }
}