swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
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

use std::thread;
use std::time::Duration;

use async_slot as slot;

use config::{Configurator};


fn updater(tx: slot::Sender<()>, mut configurator: Configurator) {
    loop {
        thread::sleep(Duration::new(10, 0));
        match configurator.try_update() {
            Ok(false) => {}
            Ok(true) => {
                tx.swap(()).expect("Can send updated config");
            }
            Err(e) => {
                error!("Reading new config: {}", e);
            }
        }
    }
}

pub fn update_thread(configurator: Configurator) -> slot::Receiver<()> {
    let (tx, rx) = slot::channel();
    thread::spawn(move || updater(tx, configurator));
    return rx;
}