文件监控系统反应编程

Question

我正在使用C#.I是新的反应式编程。使用反应性编程，我想创建一个文件夹监控系统，如果文件夹A包含任何文件(如果是的话)，那么它将抓取该文件并将其移动到文件夹B中。假设文件夹A是空的，first.User会将一些文件实时添加到文件夹A中。系统检测到已经添加了新的文件&它将一个接一个地或同时处理它。我无法理解我应该使用什么创建或间隔，然后我的处理代码将在哪里编写，请帮助我。

Answer 1

这一点应该相当接近：

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)));