cron_rs 0.1.6

A Cron Parser Library And Job Scheduler Written In Rust
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

use std::io::prelude::*;
use error::Error;
use time;
use std::time as stdtime;
use std::thread;

const MAXREADBUFFERSIZE: usize = 65536;

pub struct Message {
    pub jobId: u64,
    pub kind: String,
    pub startUnixTimeNs: u64,
    pub endUnixTimeNs: u64,
    pub body: String,
}

pub struct OutputChunkIterator<B> {
    buf: B,
}

impl<B: BufRead> OutputChunkIterator<B> {
    pub fn new(buf: B) -> OutputChunkIterator<B> {
        OutputChunkIterator { buf: buf }
    }
}

impl<B: BufRead> Iterator for OutputChunkIterator<B> {
    type Item = Result<String, Error>;

    fn next(&mut self) -> Option<Result<String, Error>> {
        let mut chunk = String::new();
        let mut buffer = [0; MAXREADBUFFERSIZE];

        loop {
            // task will be executed in the zero seconds,
            // so, just take easy :)
            if time::now().tm_sec == 59 {
                break;
            } else {
                match self.buf.read(&mut buffer[..]) {
                    Ok(0) => break,
                    Ok(n) => chunk.push_str(&String::from_utf8_lossy(&buffer[..n])),
                    Err(e) => return Some(Err(Error::ErrRead(e.to_string()))),
                }

                thread::sleep(stdtime::Duration::from_millis(300))
            }
        }

        if chunk.len() == 0 {
            None
        } else {
            Some(Ok(chunk))
        }
    }
}