Struct Walker 

pub struct Walker { /* private fields */ }

异步目录遍历器

Implementations

impl Walker

pub fn new() -> Result<Self, WalkError>

创建新的遍历器

pub fn with_options(options: WalkOptions) -> Result<Self, WalkError>

使用指定选项创建新的遍历器

pub async fn walk<P: AsRef<Path>>( &self, path: P, ) -> Result<impl Stream<Item = Result<WalkEntry, WalkError>> + Unpin + use<P>, WalkError>

遍历目录

返回一个 Stream，用于流式获取遍历结果，避免一次性收集所有条目导致的内存使用过高问题。

Examples

use itools_walker::Walker;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() {
    let walker = Walker::new().unwrap();
    let mut stream = walker.walk(".").await.unwrap();

    while let Some(entry) = stream.next().await {
        match entry {
            Ok(walk_entry) => println!("Found: {:?}", walk_entry.path),
            Err(e) => println!("Error: {:?}", e),
        }
    }
}

pub async fn walk_with<P: AsRef<Path>, F: Fn(&WalkEntry) -> Result<(), WalkError>>( &self, path: P, callback: F, ) -> Result<(), WalkError>

遍历目录并对每个条目执行回调

Trait Implementations

impl Clone for Walker

fn clone(&self) -> Walker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Walker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.