Observable 有可能以非同步的方式,也許是從不同的執行緒呼叫其觀察者的方法。這可能會使 Observable 違反Observable 契約,例如,它可能會在其中一個 OnNext
通知之前嘗試傳送 OnCompleted
或 OnError
通知,或者它可能會從兩個不同的執行緒同時發出 OnNext
通知。您可以使用 Serialize 運算子強制此類 Observable 表現良好且同步。
待定
RxGroovy 將此運算子實作為 serialize
。預設情況下,它不在任何特定的排程器上運行。
serialize()
RxJava 將此運算子實作為 serialize
。預設情況下,它不在任何特定的排程器上運行。
serialize()
待定
待定