Lochnair-Labs/irtt-rs
2
0 Fork 0
Code Issues 1 Pull Requests 4 Actions 4 Packages Projects Releases 6 Wiki Activity

fix(tui): bound input event draining #64

Merged
Lochnair merged 1 commits from fix/tui-bound-input-drain into main 2026-08-10 17:25:04 +00:00
Conversation 0 Commits 1 Files Changed 1
+6 -1
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/irtt-cli/src/cmd/tui/run.rs
+6 -1
View File
@@ -26,6 +26,7 @@ use irtt_client::managed::{
const RENDER_INTERVAL: Duration = Duration::from_millis(250); const RENDER_INTERVAL: Duration = Duration::from_millis(250);
const TUI_WAIT_SLICE: Duration = Duration::from_millis(20); const TUI_WAIT_SLICE: Duration = Duration::from_millis(20);
const MANAGED_EVENT_CAPACITY: usize = 16_384; const MANAGED_EVENT_CAPACITY: usize = 16_384;
const INPUT_EVENT_WORK_BUDGET: usize = 128;
pub fn run_tui( pub fn run_tui(
args: TuiArgs, args: TuiArgs,
@@ -216,7 +217,10 @@ fn drain_final_tui_events(
} }
fn handle_input(state: &mut TuiState, shutdown_requested: &AtomicBool) -> io::Result<bool> { fn handle_input(state: &mut TuiState, shutdown_requested: &AtomicBool) -> io::Result<bool> {
let mut force_render = false; let mut force_render = false;
while event::poll(Duration::ZERO)? { for _ in 0..INPUT_EVENT_WORK_BUDGET {
if !event::poll(Duration::ZERO)? {
break;
}
let Event::Key(key) = event::read()? else { let Event::Key(key) = event::read()? else {
continue; continue;
}; };
@@ -231,6 +235,7 @@ fn handle_input(state: &mut TuiState, shutdown_requested: &AtomicBool) -> io::Re
state.quit_requested = true; state.quit_requested = true;
shutdown_requested.store(true, Ordering::Relaxed); shutdown_requested.store(true, Ordering::Relaxed);
force_render = true; force_render = true;
break;
} }
KeyCode::Char('r') => { KeyCode::Char('r') => {
state.clear_visible_history(); state.clear_visible_history();