minions 0.2.2

Experimental actor library, under constant development.
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

use lossyq::spsc::Receiver;
use std::fmt;

#[derive(Copy,Clone,Debug)]
pub enum Message<T: Send>
{
  Empty,                      //
  Value(T),                   //
  Ack(usize,usize),           // from-to
  Error(usize,&'static str),  // error at
}

#[derive(Debug)]
pub enum Schedule {
  Loop,
  OnMessage(u64),
  EndPlusUSec(u64),
  StartPlusUSec(u64),
  Stop,
}

pub trait Reporter {
  fn message_sent(&mut self, channel_id: usize, last_msg_id: usize);
}

pub trait Task {
  fn execute(&mut self, reporter: &mut Reporter) -> Schedule;
  fn name(&self)  -> &String;
}

#[derive(Copy,Clone,Debug)]
pub enum Direction {
  In,
  Out
}

#[derive(Clone,Debug)]
pub struct Id {
  task_name  : String,
  dir        : Direction,
  id         : usize,
}

pub struct IdentifiedReceiver<Input: Send> {
  pub id    : Id,
  pub input : Receiver<Message<Input>>,
}

impl fmt::Display for Id {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "Id:({} {:?} {})", self.task_name, self.dir, self.id)
    }
}

pub fn new_id(name: String, dir: Direction, id: usize) -> Id {
  Id {
    task_name  : name,
    dir        : dir,
    id         : id,
  }
}