了解大理石图

Observable 可以被认为只是一系列事件。定义 Observable 时,你有三个侦听器:onNext,onComplete 和 onError。每次 observable 获取新值时都会调用 onNext。如果父 Observable 通知它已完成生成更多值,则将调用 onComplete。如果在执行 Observable 链期间随时抛出异常,则调用 onError。为了在 Rx 中显示操作符,大理石图用于显示特定操作所发生的情况。下面是一个简单的 Observable 运算符 Just 的示例。

StackOverflow 文档

大理石图具有表示正在执行的操作的水平块,表示已完成事件的垂直条,表示错误的 X,以及表示值的任何其他形状。考虑到这一点,我们可以看到 Just 将只取我们的值并执行 onNext,然后使用 onComplete 完成。还有很多操作只是 Just。你可以在 ReativeX 站点上看到 ReactiveX 项目中的所有操作以及 RxJava 中的实现 。通过 RxMarbles 网站还有交互式大理石图。