转化一个Observable是有趣的,但是如果有很多Observable 需要一起协作呢?如果您来自传统的充满线程和执行器的Java并发编程的话,您知道共享可变状态和同步有多难。幸运的是,在这种情况下,RxJava更有效。另外,在涉及多个流的所有操作符中,库中都有一致的处理错误的方法。如果任何上游数据源发出Error通知,它将被转发到下游,并以一个错误完成下游序列(我们之前讲过,Error和Completion都是结束的标识)。如果有超过一个的上游Observable会发出Error通知,那么第一个Error通知会成功,其他的会被丢弃(任何Observable都只会产生一个错误,参见27页的“Anatomy of rx.Observable”)。最后,如果只想继续处理事件,只有当所有的正常事件都产生完了,才会去发射Error,那么许多操作符会有一个 *DelayError变体。

results matching ""

    No results matching ""