RxJava操做符serialize 笔记<二十六>

若是您不能保证您的operator将遵照 Rx 协议，例如由于您从多个源异步推送，则能够使用serialize运算符。serialize运算符会将不可靠的可观察量转换为合法的，顺序的可观察量。

让咱们首先建立一个违反协议的observable并订阅它。

日志输出：

尽管咱们的observable试图释放，但最终结果却遵照了Rx规格。之因此发生这种状况，是由于订阅（很是合理地）认为序列结束时订阅终止了订阅。这并不意味着咱们将始终关注问题。还有一个名为unsafeSubscribe的方法，它不会自动取消订阅。

输出：

咱们订阅者的预期行为与前面的示例相同（咱们建立了一个Subscriber实例，由于unsafeSubscribe没有带lambda的重载）。可是，咱们能够在这里看到咱们没有取消订阅，咱们一直收到通知。

unsafeSubscribe在其余方面也是不安全的，例如错误处理。它的用处是有限的。文档说它应该只用于使用嵌套订阅的自定义运算符。为了保护这些operator不接收和非法序列，咱们能够应用serialize操做符。

输出：

咱们看到，尽管咱们没有取消订阅，但非法通知已被过滤掉。

 

下节再续！

原文：https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%203%20-%20Taming%20the%20sequence/7.%20Custom%20operators.md#lift