处理以前可观察到的selectmany rx

Question

我正在用以下设置监视一个目录：

var folder = new Subject();
folder.OnNext("somepath");
folder.SelectMany(FileMonitor)
.Subscribe(x => Console.WriteLine($"Found: {x}"));
public IObservable<string> FileMonitor(string pathToWatch){
return Observable.Create<string>(obs => {
var dfs = CreateAndStartFileWatcher(pathToWatch,obs);
() => dfs.Dispose();
});
}

这是有效的，但如果我向主题传递一个新路径，则不会释放以前的FileMonitor。

有没有办法取消/处理以前生成的Observable？

看起来我需要：http://reactivex.io/documentation/operators/switch.html但这并没有在c#中实现？

Answer 1

有时候，问一个问题会给自己带来新的见解。解决方案是使用switch，可用，但仅适用于Observable。

所以应该是：

var folder = new Subject();
folder.OnNext("somepath");
folder.Select(FileMonitor)
.Switch()
.Subscribe(x => Console.WriteLine($"Found: {x}"));
public IObservable<string> FileMonitor(string pathToWatch){
return Observable.Create<string>(obs => {
var dfs = CreateAndStartFileWatcher(pathToWatch,obs);
() => dfs.Dispose();
});
}

留下这个问题供参考，而不是删除它。