termix 0.0.3

TUI framework inspired by bubbletea.
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
57
58
59
60

use std::{
    sync::{
        mpsc::{channel, Receiver, Sender},
        Arc, Mutex,
    },
    thread,
};

use crate::output::Output;

#[derive(Debug)]
pub struct StandardRenderer {
    out: Arc<Mutex<Output>>,
}

struct Notifier {}

impl StandardRenderer {
    pub fn new() -> StandardRenderer {
        StandardRenderer {
            out: Arc::new(Mutex::new(Output::new())),
        }
    }

    pub fn start(&mut self) {
        let (tx, rx) = channel();
        self.interval_refresh(tx);
        let out = self.out.clone();
        listen(out, rx);
    }

    pub fn quit(&mut self) {
        let mut o = self.out.lock().unwrap();
        o.quit();
    }

    fn interval_refresh(&self, tx: Sender<Notifier>) {
        thread::spawn(move || loop {
            let _ = tx.send(Notifier {});
        });
    }

    pub fn write(&mut self, new_data: &str) {
        let out = self.out.clone();
        let out = out.lock();
        if let Ok(mut o) = out {
            o.write(new_data);
        }
    }
}

fn listen(out: Arc<Mutex<Output>>, rx: Receiver<Notifier>) {
    thread::spawn(move || {
        while rx.recv().is_ok() {
            if let Ok(mut o) = out.lock() {
                o.flush();
            }
        }
    });
}