haltic 0.1.3

A crate for cancellable services
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

use core::time;
use haltic::{self, Cancellable};
use std::io::Write;
use std::{io, net, thread};

struct Service(net::TcpListener);

impl haltic::Cancellable for Service {
    type Error = io::Error;

    fn for_each(&mut self) -> Result<haltic::LoopState, Self::Error> {
        let mut stream = self.0.accept()?.0;
        write!(stream, "hello!")?;
        Ok(haltic::LoopState::Continue)
    }
}

impl Service {
    fn new() -> Self {
        let listener = net::TcpListener::bind("127.0.0.1:6556").unwrap();
        Service(listener)
    }
}

fn main() {
    let mut s = Service::new();
    let h = s.spawn();
    let h2 = h.clone();

    eprintln!("service started!");

    thread::spawn(move || {
        thread::sleep(time::Duration::from_secs(10));
        eprintln!("service terminating!");

        h2.cancel();
    });
    h.wait().unwrap();
    eprintln!("service terminated!");
}