mirror of https://github.com/sayanarijit/xplr
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
35 lines
1.0 KiB
Rust
35 lines
1.0 KiB
Rust
use crate::app::{ExternalMsg, MsgIn, Task};
|
|
use serde_yaml;
|
|
use std::fs;
|
|
use std::sync::mpsc::Sender;
|
|
use std::thread;
|
|
use std::time::Duration;
|
|
|
|
pub fn keep_reading(pipe: String, tx: Sender<Task>) {
|
|
thread::spawn(move || loop {
|
|
let in_str = fs::read_to_string(&pipe).unwrap_or_default();
|
|
|
|
if !in_str.is_empty() {
|
|
let msgs = in_str
|
|
.lines()
|
|
.map(|s| serde_yaml::from_str::<ExternalMsg>(s.trim()));
|
|
|
|
msgs.for_each(|msg| match msg {
|
|
Ok(m) => {
|
|
tx.send(Task::new(2, MsgIn::External(m), None)).unwrap();
|
|
}
|
|
Err(e) => {
|
|
tx.send(Task::new(
|
|
0,
|
|
MsgIn::External(ExternalMsg::LogError(e.to_string())),
|
|
None,
|
|
))
|
|
.unwrap();
|
|
}
|
|
});
|
|
fs::write(&pipe, "").unwrap();
|
|
};
|
|
thread::sleep(Duration::from_millis(10));
|
|
});
|
|
}
|