待定
在 RxGroovy 中,此过滤操作符实现为 last
和 lastOrDefault
。
有点令人困惑的是,还有一些名为 last
和 lastOrDefault
的 BlockingObservable
操作符会阻塞并返回项目,而不是立即返回 Observable。
last
和 lastOrDefault
默认情况下不会在任何特定的 Scheduler 上操作。
BlockingObservable
方法BlockingObservable
方法不会将 Observable 转换为另一个过滤的 Observable,而是会从 Observable 级联中退出,阻塞直到 Observable 发射所需的项目,然后返回该项目本身。
要将 Observable 转换为 BlockingObservable
以便您可以使用这些方法,您可以使用 Observable.toBlocking
或 BlockingObservable.from
方法。
Observable.toBlocking()
BlockingObservable.from(Observable)
在 RxJava 中,此过滤操作符实现为 last
和 lastOrDefault
。
有点令人困惑的是,还有一些名为 last
和 lastOrDefault
的 BlockingObservable
操作符会阻塞并返回项目,而不是立即返回 Observable。
last
和 lastOrDefault
默认情况下不会在任何特定的 Scheduler 上操作。
BlockingObservable
方法BlockingObservable
方法不会将 Observable 转换为另一个过滤的 Observable,而是会从 Observable 级联中退出,阻塞直到 Observable 发射所需的项目,然后返回该项目本身。
要将 Observable 转换为 BlockingObservable
以便您可以使用这些方法,您可以使用 Observable.toBlocking
或 BlockingObservable.from
方法。
Observable.toBlocking()
BlockingObservable.from(Observable)
last
位于以下每个发行版中
rx.all.js
rx.all.compat.js
rx.aggregates.js
它需要以下发行版之一
rx.js
rx.compat.js
rx.lite.js
rx.lite.compat.js