Struct ProgressReporter 

pub struct ProgressReporter { /* private fields */ }

Reports processing progress from a node back to the caller (UI, CLI, etc.).

Wraps an optional boxed closure. Some(callback) for real reporting, None for no-op mode (used in tests).

Implementations

impl ProgressReporter

pub fn new(callback: impl Fn(u32, &str) + 'static) -> Self

Create a new ProgressReporter with a callback function.

The callback receives two arguments:

1. progress (u32, 0-100) — percentage complete
2. message (&str) — human-readable status text

USAGE:

use bnto_core::ProgressReporter;

// Simple logger
let reporter = ProgressReporter::new(|percent, message| {
    println!("{}% — {}", percent, message);
});

// In a WASM bridge, wrap a js_sys::Function:
// let reporter = ProgressReporter::new(move |percent, message| {
//     let _ = js_callback.call2(&JsValue::NULL, &percent.into(), &message.into());
// });

pub fn new_noop() -> Self

Create a no-op reporter that discards all progress updates. Used in tests where we don’t need progress reporting.

pub fn with_output( callback: impl Fn(u32, &str) + 'static, output_callback: impl Fn(&str) + 'static, ) -> Self

Create a reporter with both progress and output callbacks.

The output callback receives streaming lines from child process stderr (e.g. yt-dlp download progress). Used by the executor to relay command output to PipelineEvent::CommandOutput.

pub fn report(&self, percent: u32, message: &str)

Report progress to the caller.

Arguments:

• percent — how far along we are (0 to 100)
• message — what we’re currently doing (“Compressing image 3/10…”)

pub fn report_output(&self, line: &str)

Report a line of streaming output from a child process.

Called by processors that use run_command_streaming() to relay stderr lines (e.g. yt-dlp progress) to the pipeline reporter.