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
|
use std::collections::VecDeque;
use std::sync::mpsc;
use crate::config;
use crate::io::IOWorkerThread;
use crate::tab::JoshutoTab;
use crate::util::event::Events;
pub const MESSAGE_VISIBLE_DURATION: usize = 1;
pub struct JoshutoContext {
pub exit: bool,
pub curr_tab_index: usize,
pub tabs: Vec<JoshutoTab>,
pub worker_queue: VecDeque<IOWorkerThread>,
pub worker_msg: Option<String>,
pub message_queue: VecDeque<String>,
pub events: Events,
pub config_t: config::JoshutoConfig,
}
impl JoshutoContext {
pub fn new(config_t: config::JoshutoConfig) -> Self {
JoshutoContext {
exit: false,
curr_tab_index: 0,
tabs: Vec::new(),
worker_queue: VecDeque::with_capacity(10),
worker_msg: None,
message_queue: VecDeque::with_capacity(4),
events: Events::new(),
config_t,
}
}
pub fn curr_tab_ref(&self) -> &JoshutoTab {
&self.tabs[self.curr_tab_index]
}
pub fn curr_tab_mut(&mut self) -> &mut JoshutoTab {
&mut self.tabs[self.curr_tab_index]
}
pub fn add_new_worker(&mut self, thread: IOWorkerThread) {
self.worker_queue.push_back(thread);
}
pub fn push_tab(&mut self, tab: JoshutoTab) {
self.tabs.push(tab);
self.curr_tab_index = self.tabs.len() - 1;
}
}
|
