文件监控系统反应式编程

我正在使用 C#。我是反应式编程的新手。 使用反应式编程，我想创建一个文件夹监视系统，如果文件夹 A 包含任何文件，它将调用该系统（如果是），那么它将抓取该文件并处理它并将其移动到文件夹 B 中。 假设文件夹 A 首先是空的。用户实时向文件夹 A 中添加一些文件。系统检测到有新文件添加，会一一或同时处理。 我无法理解应该使用 Create 或 Interval 以及之后我的处理代码将写入哪里 请帮我

这应该相当接近：

var query =
    Observable
        .Using(
            () =>
            {
                var fsw = new FileSystemWatcher(@"C:\A");
                fsw.EnableRaisingEvents = true;
                return fsw;
            },
            fsw => Observable.FromEventPattern<FileSystemEventHandler, FileSystemEventArgs>(
                h => fsw.Created += h,
                h => fsw.Created -= h))
        .Delay(TimeSpan.FromSeconds(0.1));


query
    .Subscribe(x => File.Move(x.EventArgs.FullPath, Path.Combine(@"C:\B", x.EventArgs.Name)));