Observable 可能异步地调用其观察者的方法,可能来自不同的线程。这可能导致此类 Observable 违反 Observable 协议,因为它可能会在其中一个 OnNext 通知之前发送 OnCompleted 或 OnError 通知,或者它可能并发地从两个不同的线程发出 OnNext 通知。您可以通过将 Serialize 操作符应用于 Observable 来强制它保持良好行为和同步。
OnNext
OnCompleted
OnError
serialize
待定
RxGroovy 将此操作符实现为 serialize。默认情况下,它不会在任何特定的 Scheduler 上运行。
serialize()
RxJava 将此操作符实现为 serialize。默认情况下,它不会在任何特定的 Scheduler 上运行。
Synchronize
synchronize