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

推荐订阅源

D
Docker
I
InfoQ
L
LangChain Blog
阮一峰的网络日志
阮一峰的网络日志
Y
Y Combinator Blog
博客园_首页
Martin Fowler
Martin Fowler
宝玉的分享
宝玉的分享
A
About on SuperTechFans
Apple Machine Learning Research
Apple Machine Learning Research
Vercel News
Vercel News
T
The Blog of Author Tim Ferriss
C
Check Point Blog
B
Blog RSS Feed
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Engineering at Meta
Engineering at Meta
B
Blog
爱范儿
爱范儿
Stack Overflow Blog
Stack Overflow Blog
aimingoo的专栏
aimingoo的专栏
WordPress大学
WordPress大学
F
Fortinet All Blogs
月光博客
月光博客
GbyAI
GbyAI

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