blob: 96fef8d6b74e18da7df68c49de55a1e9eb792e08 (
plain)
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
|
use chan::{Sender, Receiver};
use std::process;
use std::sync::{Arc, Mutex};
use datatype::{Command, Event};
/// Encapsulates a `Command` to be sent to the `GlobalInterpreter` for processing,
/// with an optional channel to receive the outcome `Event`.
pub struct Interpret {
pub command: Command,
pub response_tx: Option<Arc<Mutex<Sender<Event>>>>,
}
/// A `Gateway` may send `Command`s to the `GlobalInterpreter`, as well as listen
/// to the system-wide `Event` messages.
pub trait Gateway {
fn initialize(&mut self, itx: Sender<Interpret>) -> Result<(), String>;
fn start(&mut self, itx: Sender<Interpret>, erx: Receiver<Event>) {
self.initialize(itx).unwrap_or_else(|err| {
error!("couldn't start gateway: {}", err);
process::exit(1);
});
loop {
self.pulse(erx.recv().expect("all gateway event transmitters are closed"));
}
}
fn pulse(&self, _: Event) {} // ignore global events by default
}
|