Struct EventReader 

pub struct EventReader { /* private fields */ }

Blocking event pump that forwards terminal events to the async AppEvent channel.

EventReader must run on a dedicated std::thread — it calls blocking_send and crossterm’s blocking poll, which would stall a tokio worker thread.

Examples

use std::time::Duration;
use tokio::sync::mpsc;
use zeph_tui::EventReader;

let (tx, rx) = mpsc::channel(64);
let reader = EventReader::new(tx, Duration::from_millis(250));
std::thread::spawn(|| reader.run());

Implementations

impl EventReader

pub fn new(tx: Sender<AppEvent>, tick_rate: Duration) -> Self

Create a new reader that sends events to tx at up to tick_rate cadence.

Examples

use std::time::Duration;
use tokio::sync::mpsc;
use zeph_tui::EventReader;

let (tx, _rx) = mpsc::channel(64);
let reader = EventReader::new(tx, Duration::from_millis(250));

pub fn run(self)

Start the blocking event loop using the default CrosstermEventSource.

Must be called from a dedicated std::thread, not a tokio worker. Returns when the AppEvent channel receiver is dropped.

pub fn run_with_source(self, source: impl EventSource)

Start the blocking event loop with a custom EventSource.

This variant exists primarily for testing with mock sources. Returns when the source returns None or the channel is closed.