d3-components 0.1.2

A framework for server development -- the component layer
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
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

# Rust Component Layer for D3 -- A Framework for Server Development

[![Build Status](https://github.com/BruceBrown/d3/workflows/Rust/badge.svg)](
https://github.com/brucebrown/d3/actions)
[![Test Status](https://github.com/BruceBrown/d3/workflows/Tests/badge.svg)](
https://github.com/brucebrown/d3/actions)
[![License](https://img.shields.io/badge/license-MIT%20OR%20Apache--2.0-blue.svg)](
https://github.com/BruceBrown/d3#license)
[![Cargo](https://img.shields.io/crates/v/d3-components.svg)](
https://crates.io/crates/d3-components)
[![Documentation](https://docs.rs/d3-components/badge.svg)](
https://docs.rs/d3-components)
[![Rust 1.47+](https://img.shields.io/badge/rust-1.47+-color.svg)](
https://www.rust-lang.org)

The components layer provides an organization hierarchy for machines.
It is based upon a Component/Coordinator/Connector model, and while not the only possible model, it is one I like.
This layer is where the network is exposed. It is an adapter wrapping Mio.

## Usage

Add this to your `Cargo.toml`:

```toml
[dependencies]
d3-derive = "0.1.2"
d3-core = "0.1.2"
d3-components = "0.1.2"
```


## Example Listening on an address:port
```rust
#[macro_use]
extern crate d3_derive;

use d3_core::machine_impl::*;
use d3_core::executor;
use d3_components::network;

// A trivial Alice
pub struct Alice {}

// Implement the Machine trait for Alice
impl Machine<network::NetCmd> for Alice {
     fn receive(&self, cmd: StateTable) {
     }
}

// Start the scheduler and executor and network
executor::start_server();
network::start_network();

// create the Machine from Alice, getting back a machine and Sender<StateTable>.
let (alice, sender) = executor::connect(Alice{});

// send a command to the network asking for Alice to 
// be notified if a connection is received for 127.0.0.1:4000
let cmd = NetCmd::BindListener("127.0.0.1:4000".to_string, sender);
network::get_network_sender().send(cmd).expect("send failed");

// Stop the scheduler and executor and network
network::start_network();
executor::stop_server();
```