如何解决如何取消使用Rx调用的异步方法
| 我想知道如何取消\停止使用asynchronous0ѭ使用反应式扩展的异步方法。 因此,我希望能够取消\\停止以下方法:this.booksService.Search(searchText)
.ObserveOndispatcher()
.Subscribe(results =>
{
this.books.Clear();
this.books.AddRange(results);
});
解决方法
处置值时,
Subscribe()
的返回值为IDisposable
,如下所示:
var searchSub = this.booksService
.Search(searchText) ...
.Subscribe( ... );
// do something else
searchSub.Dispose();
订阅已停止。这实际上会停止基础的“书籍服务”搜索吗?这取决于实现方式。如果用Observable.Create
完成,那么很有可能会得到这种行为。
, 您将不得不告诉booksService
取消搜索。 Search
方法开始搜索,并且还返回IObservable
。搜索完成后,将在IObservable
上调用OnNext
。在ѭ7中启动了一些异步代码,您需要取消这些代码。
, 我的建议是将搜索方法更改为以CancellationToken作为第二个参数的异步调用。然后,您可以通过Observable.ToAsync将其转换为Observable序列。然后,在此可观察对象上调用dispose将触发CancellationToken的取消。这样做可以使您轻松地将令牌传递到异步网络调用等。
public Task Search(string searchText,CancellationToken cancel)
{
// Pass the token on to the async webclient request etc.
}
var searchSub = Observable.ToAsync(c => this.booksService.Search(searchText,c))
.Subscribe( ... );
// do something else
searchSub.Dispose();
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。