kdheepak/taskwarrior-tui
1
0
Fork 0
mirror of https://github.com/kdheepak/taskwarrior-tui.git synced 2025-08-25 17:57:19 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove pause_stdin

Browse source
This commit is contained in:
Dheepak Krishnamurthy 2021-03-31 00:41:20 -06:00
parent e53b8af73b
commit 61d917360b
2 changed files with 5 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/main.rs
View file

@ -96,13 +96,13 @@ async fn tui_main(_config: &str) -> Result<()> {
match events.next().await? {
Event::Input(input) => {
if input == app.keyconfig.edit {
events.pause_key_capture(&mut terminal);
events.leave_tui_mode(&mut terminal);
}
let r = app.handle_input(input);
if input == app.keyconfig.edit {
events.resume_key_capture(&mut terminal);
events.enter_tui_mode(&mut terminal);
}
if r.is_err() {
destruct_terminal();

33
src/util.rs
View file

@ -68,26 +68,17 @@ pub fn destruct_terminal() {
pub struct Events {
pub rx: async_std::channel::Receiver<Event<Key>>,
pub pause_stdin: Arc<AtomicBool>,
}
impl Events {
pub fn with_config(config: EventConfig) -> Events {
use crossterm::event::{KeyCode::*, KeyModifiers};
let pause_stdin = Arc::new(AtomicBool::new(false));
let tick_rate = config.tick_rate;
let (tx, rx) = unbounded::<Event<Key>>();
let ps = pause_stdin.clone();
task::spawn_local(async move {
let mut reader = EventStream::new();
loop {
if ps.load(Ordering::SeqCst) {
task::sleep(Duration::from_millis(250)).await;
task::yield_now().await;
continue;
}
let mut delay = Delay::new(tick_rate).fuse();
let mut event = reader.next().fuse();
@ -130,7 +121,7 @@ impl Events {
}
}
});
Events { rx, pause_stdin }
Events { rx }
}
/// Attempts to read an event.
@ -139,33 +130,15 @@ impl Events {
self.rx.recv().await
}
pub async fn pause_event_loop(&self) {
self.pause_stdin.store(true, Ordering::SeqCst);
task::yield_now().await;
while !self.pause_stdin.load(Ordering::SeqCst) {
task::sleep(Duration::from_millis(50)).await;
}
}
pub async fn resume_event_loop(&self) {
self.pause_stdin.store(false, Ordering::SeqCst);
task::yield_now().await;
while self.pause_stdin.load(Ordering::SeqCst) {
task::sleep(Duration::from_millis(50)).await;
}
}
pub fn pause_key_capture(&self, terminal: &mut Terminal<CrosstermBackend<io::Stdout>>) {
task::block_on(self.pause_event_loop());
pub fn leave_tui_mode(&self, terminal: &mut Terminal<CrosstermBackend<io::Stdout>>) {
disable_raw_mode().unwrap();
execute!(io::stdout(), LeaveAlternateScreen, DisableMouseCapture).unwrap();
terminal.show_cursor().unwrap();
}
pub fn resume_key_capture(&self, terminal: &mut Terminal<CrosstermBackend<io::Stdout>>) {
pub fn enter_tui_mode(&self, terminal: &mut Terminal<CrosstermBackend<io::Stdout>>) {
execute!(io::stdout(), EnterAlternateScreen, EnableMouseCapture).unwrap();
enable_raw_mode().unwrap();
task::block_on(self.resume_event_loop());
terminal.resize(terminal.size().unwrap()).unwrap();
}
}