如何解决处置以前的可观察选择许多 rx
我正在使用以下设置监控目录:
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# 中实现的吗?
解决方法
有时,提出问题会给自己带来新的见解。
解决方案是使用 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();
});
}
留下这个问题以供参考,而不是删除它。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。