c# - 如何取消使用 Rx 调用的异步方法

Question

我想知道如何使用 TakeUntil 取消\停止使用响应式扩展调用的异步方法。

所以我希望能够取消\停止下面的方法:

this.booksService.Search(searchText)
                 .ObserveOnDispatcher()
                 .Subscribe(results =>
                 {
                    this.books.Clear();
                    this.books.AddRange(results);
                 });

Answer 1

Subscribe() 的返回值是一个 IDisposable，当您释放该值时，如下所示:

var searchSub = this.booksService
                    .Search(searchText) ...
                    .Subscribe( ... );
// do something else
searchSub.Dispose();

订阅已停止。这真的会停止底层的 booksSevice 搜索吗？这取决于实现。如果使用 Observable.Create 完成，那么很可能会出现这种行为。