Struct ParallelMultiWalker 

pub struct ParallelMultiWalker { /* private fields */ }

Walks independent raw roots concurrently while preserving root order.

Implementations

impl ParallelMultiWalker

pub fn visit<F>(self, visitor: F) -> Result<ParallelMultiVisitReport, WalkError>

where F: for<'entry> Fn(ParallelMultiWalkEvent<'entry>) -> WalkControl + Send + Sync + 'static,

Streams every configured root through one concurrent callback.

Callback order is intentionally unspecified. Each event carries its root insertion index, while the returned per-root reports preserve insertion order. WalkControl::Quit cancels every active root.

Errors

Returns the first root error in insertion order after all started root workers have joined.

Panics

Panics if the callback or an internal root worker panics.

pub fn visit_with_cancellation<F>( self, cancellation: &CancellationToken, visitor: F, ) -> Result<ParallelMultiVisitReport, WalkError>

where F: for<'entry> Fn(ParallelMultiWalkEvent<'entry>) -> WalkControl + Send + Sync + 'static,

Multi-root streaming traversal with shared cooperative cancellation.

Returning WalkControl::Quit cancels the supplied token so every active and not-yet-started root observes the same stop request.

Errors

Returns the first root error in insertion order after all started root workers have joined.

Panics

Panics if the callback or an internal root worker panics.

impl ParallelMultiWalker

pub fn new(root: impl Into<PathBuf>) -> Self

pub fn add_root(self, root: impl Into<PathBuf>) -> Self

pub const fn options(self, options: WalkOptions) -> Self

pub const fn with_root_parallelism(self, parallelism: usize) -> Self

Sets concurrently active roots. Zero uses available parallelism.

pub const fn with_traversal_parallelism(self, parallelism: usize) -> Self

Sets directory workers requested by each active root.

pub fn runtime(self, runtime: ParallelRuntime) -> Self

Selects the executor shared by all active roots.

pub const fn skip_stdout(self, enabled: bool) -> Self

Skips a regular file that refers to redirected standard output.

pub fn walk(self) -> Result<ParallelMultiWalkReport, WalkError>

Walks every root and returns reports in insertion order.

Errors

Returns the first root error in insertion order after all started root workers have joined.

Panics

Panics if an internal root worker panics.