惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

Jina AI
Jina AI
云风的 BLOG
云风的 BLOG
人人都是产品经理
人人都是产品经理
T
The Blog of Author Tim Ferriss
阮一峰的网络日志
阮一峰的网络日志
罗磊的独立博客
J
Java Code Geeks
博客园 - 聂微东
B
Blog
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
WordPress大学
WordPress大学
腾讯CDC
L
LangChain Blog
Apple Machine Learning Research
Apple Machine Learning Research
Microsoft Azure Blog
Microsoft Azure Blog
D
DataBreaches.Net
The GitHub Blog
The GitHub Blog
美团技术团队
博客园 - Franky
Google DeepMind News
Google DeepMind News
V
V2EX
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
月光博客
月光博客
The Cloudflare Blog

DEV Community

Authentication Security Deep Dive: From Brute Force to Salted Hashing (With Java Examples) Why AI Systems Don’t Fail — They Drift Spilling beans for how i learn for exam😁"Reinforcement Learning Cheat Sheet" I Replaced Chrome with Safari for AI Browser Automation. Here's What Broke (and What Finally Worked) How Python Borrows Other People's Work The $40 Architecture: Processing 1 Billion API Requests with 99.99% Uptime Vibe Coding: A Workflow Guide (From Zero to SaaS) Most webhook security guides protect the wrong side. The scary part is delivery. Headless CMS for TanStack Start: Build a Blog with Cosmic EU Age Verification App "Hacked in 2 Minutes" — What Actually Happened Comfy Cloud’s delete function does not actually remove files Running AI Models on GPU Cloud Servers: A Beginner Guide Event-driven media intelligence with AWS Step Functions and Bedrock I scored 500 AI prompts across 8 quality dimensions — here's what broke How to Call Google Gemini API from Next.js (Free Tier, No Backend Needed) The Portal Protocol: Reclaiming Human Connection in the Age of AI How to Fix Your Team's Scattered Knowledge Problem With a Self-Hosted Forum Intro to tc Cloud Functors: A Graph-First Mental Model for the Modern Cloud Designing Multi-Tenant Backends With Both Ownership and Team Access I Built a Neumorphic CSS Library with 77+ Components — Here's What I Learned PostgreSQL Performance Optimization: Why Connection Pooling Is Critical at Scale Cómo construí un SaaS multi-rubro para gestionar expensas en Argentina con FastAPI + Vue 3 🚀 I Built an Ethical Hacking Scanner Tool – Open Source Project I Replaced /usage and /context in Claude Code With a Single Statusline A Pythonic Way to Handle Emails (IMAP/SMTP) with Auto-Discovery and AI-Ready Design I Collected 8.9 Million Polymarket Price Points — Here's What I Found About How Markets Really Move EcoTrack AI — Carbon Footprint Tracker & Dashboard Everyone's Using AI. No One Agrees How. 5 self-hosted ebook managers worth trying in 2026 Building Your First AI Agent with LangChain: From Chatbot to Autonomous Assistant
Watching a Folder in Rust with notify-rs — Hot Folder for...
hiyoyo · 2026-04-27 · via DEV Community
Cover image for Watching a Folder in Rust with notify-rs — Hot Folder for PDF Automation

hiyoyo

All tests run on an 8-year-old MacBook Air.

Drop a PDF into a folder. By the time you look at your screen, it's already been processed.

That's the Hot Folder feature — and it's powered by notify, a cross-platform file system watcher for Rust.


Basic setup

use notify::{Config, Event, RecommendedWatcher, RecursiveMode, Watcher};
use std::path::Path;
use std::sync::mpsc;

pub fn watch_folder(
    folder: &Path,
    tx: mpsc::Sender>,
) -> notify::Result {
    let mut watcher = RecommendedWatcher::new(
        move |res| { tx.send(res).unwrap(); },
        Config::default(),
    )?;

    watcher.watch(folder, RecursiveMode::NonRecursive)?;
    Ok(watcher)
}

Enter fullscreen mode Exit fullscreen mode

RecommendedWatcher uses FSEvents on macOS — low overhead, near-instant detection.


Handling events

Not every event should trigger the pipeline. Filter for file creation only, and only for PDFs:

pub fn handle_events(rx: mpsc::Receiver>) {
    for res in rx {
        match res {
            Ok(event) => {
                if event.kind.is_create() {
                    for path in event.paths {
                        if path.extension().map_or(false, |e| e == "pdf") {
                            tokio::spawn(run_pipeline(path));
                        }
                    }
                }
            }
            Err(e) => eprintln!("watch error: {e}"),
        }
    }
}

Enter fullscreen mode Exit fullscreen mode


The debounce problem

File creation events fire multiple times for a single file — once when the file is created, again as bytes are written. Processing a half-written PDF will fail.

Fix: wait for the Modify events to stop before processing.

use notify::Config;
use std::time::Duration;

// Built-in debounce via notify-debouncer-mini
use notify_debouncer_mini::{new_debouncer, DebounceEventResult};

let (tx, rx) = mpsc::channel::();

let mut debouncer = new_debouncer(
    Duration::from_millis(500),  // wait 500ms after last event
    move |res| { tx.send(res).unwrap(); },
)?;

Enter fullscreen mode Exit fullscreen mode

500ms after the last write event — the file is complete. Process it then.


Wiring into Tauri

The watcher runs in a background thread. When the user adds or removes a watched folder from the UI, send a message to that thread:

pub enum WatcherCommand {
    Add(PathBuf),
    Remove(PathBuf),
    Shutdown,
}

Enter fullscreen mode Exit fullscreen mode

Keep the watcher alive by storing it in Tauri's managed state. Drop it on app exit.


Hiyoko PDF Vault → https://hiyokoko.gumroad.com/l/HiyokoPDFVault
X → @hiyoyok