Struct ProgressHandler 

pub struct ProgressHandler { /* private fields */ }

EventHandler that drives an indicatif ProgressBar on each node completion.

Pass as user_handler to task.schedule(). The TaskGatheringHandler chains on_close/on_timeout to us — no core changes needed.

ProgressBar is internally Arc’d, so updates from the poll thread are immediately visible to the steady-tick render thread.

Implementations

impl ProgressHandler

pub fn new(state: ProgressState, bar: ProgressBar) -> Self

Trait Implementations

impl EventHandler for ProgressHandler

fn on_close(&mut self, _node: &str, rc: i32)

Called when a connection to a node is closed.

fn on_timeout(&mut self, _node: &str)

Called when a node operation times out.

fn on_start(&mut self, worker: &dyn Worker)

Called when the worker starts.

fn on_read(&mut self, node: &str, fd: i32, msg: &[u8])

Called when data is available for reading from a node.

fn on_error(&mut self, node: &str, error: &WorkerError)

Called when an error occurs for a node.

fn take_buffers( &mut self, ) -> (HashMap<String, Vec<Vec<u8>>>, HashMap<String, Vec<Vec<u8>>>, HashSet<String>)

Extract buffered stdout/stderr data from this handler. Returns (stdout, stderr, timeouts) where stdout/stderr are node -> Vec<chunks>. Default returns empty maps. Used by Task to collect results after execution.