apis 0.5.13

Reactive, session-oriented, asynchronous process-calculus framework
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
40

//! The `sourcepoints` field is wrapped in a `Refcell` and an `Option` so that
//! it may be "removed" from the process with `take_endpoints` while the run
//! loop receives messages.

use {std, vec_map};
use macro_machines::def_machine_nodefault;
use crate::{channel, process, session};

def_machine_nodefault! {
  Inner <CTX : { session::Context }> (
    def            : process::Def <CTX>,
    session_handle : session::Handle <CTX>,
    sourcepoints   : vec_map::VecMap <Box <dyn channel::Sourcepoint <CTX>>>,
    endpoints      : std::cell::RefCell <Option <
      vec_map::VecMap <Box <dyn channel::Endpoint <CTX>>>>>
  ) @ _inner {
    STATES [
      state Ready   ()
      state Running ()
      state Ended   ()
    ]
    EVENTS [
      event Run <Ready>   => <Running> ()
      event End <Running> => <Ended>   ()
      //event Tick    <Running> => <Running> ()
      //event Update  <Running> => <Running> ()
      //event Message <Running> => <Running> ()
      //event Abort   <Ready>   => <Ended>   ()
      //event Reset   <Running> => <Ready>   ()
      //event Resume  <Ended>   => <Running> ()
      //event Restart <Ended>   => <Ready>   ()
    ]
    initial_state:  Ready
    terminal_state: Ended {
      terminate_failure: {
        panic!("process dropped in state: {:?}", _inner.state().id());
      }
    }
  }
}