RxJava操作符serialize 笔记-二十六

如果您不能保证您的operator将遵守 Rx 协议，例如因为您从多个源异步推送，则可以使用serialize运算符。serialize运算符会将不可靠的可观察量转换为合法的，顺序的可观察量。 让我们首先创建一个违反协议的observable并订阅它。 日志输出： 尽管我们的observable试图释放，但最终结果却遵守了Rx规格。之所以发生这种情况，是因为订阅（非常合理地）认为序列结束时订阅终止

>>阅读原文<<