Struct ProgressRegistry 

pub struct ProgressRegistry { /* private fields */ }

Global registry for progress events

Uses a lock-free queue for event storage and broadcast channel for real-time subscribers.

Implementations

impl ProgressRegistry

pub fn new() -> Arc<Self>

Create a new progress registry

pub fn start_operation( self: &Arc<Self>, source: &str, granularity: ProgressGranularity, ) -> ProgressHandle

Start a new operation and return a handle for reporting progress

pub fn subscribe(&self) -> Receiver<ProgressEvent>

Subscribe to real-time progress events

pub fn poll(&self) -> Option<ProgressEvent>

Poll for a single event (non-blocking)

pub fn poll_all(&self) -> Vec<ProgressEvent>

Poll all available events (non-blocking)

pub fn try_recv(&self) -> Option<ProgressEvent>

Try to receive a single event (non-blocking, alias for poll)

pub fn is_empty(&self) -> bool

Check if the queue is empty

Trait Implementations

impl Default for ProgressRegistry

fn default() -> Self

Returns the “default value” for a type.