mactime2 3.2.0

Replacement for `mactime`
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

use std::{
    io::stdin,
    sync::mpsc::{self, Receiver, Sender},
    thread::{self, JoinHandle},
};

use anyhow::Result;

use crate::{stream::*, Joinable, Provider};

pub(crate) trait StreamReader<T, R>: Sized + StreamWorker<T> + Joinable<R> + Provider<T, R>
where
    T: Send + 'static,
{
    fn from(filename: &Option<String>) -> Result<Self> {
        let (tx, rx): (Sender<T>, Receiver<T>) = mpsc::channel();

        let worker = match StreamSource::from(filename)? {
            StreamSource::Stdin => thread::spawn(move || {
                <Self as StreamWorker<T>>::worker(stdin(), tx);
            }),
            StreamSource::File(f) => thread::spawn(move || {
                <Self as StreamWorker<T>>::worker(f, tx);
            }),
        };

        Ok(<Self as StreamReader<T, R>>::new(worker, rx))
    }

    fn new(worker: JoinHandle<()>, rx: Receiver<T>) -> Self;
}