240 发简信
IP属地:湖北
  • “在这个例子里我们第二根水管只发送了三个事件然后就发送了Complete, 这个时候尽管第一根水管还有事件4 和事件Complete 没有发送, 但是它们发不发送还有什么意义呢? 所以本着节约是美德的思想, 就干脆打断它的狗腿, 不让它发了.”
    请问这里的打断狗腿的机制是什么?第二个水管发了Complete后怎么会影响到第一根水管事件的发送呢?楼主之前的文章里曾经提到过即使上游发送了Complete事件后,上游应该还是可以继续发送事件的,只是下游不再接受事件而已。与此处的说法有点矛盾,还请楼主进一步解释一下。

    给初学者的RxJava2.0教程(四)

    Outline [TOC] 前言 在上一节中, 我们提到了Flowable 和Backpressure背压, 本来这一节的确是想讲这两个东西的,可是写到一半感觉还是差点火候...

  • “若是发送多个onError, 则收到第二个onError事件会导致程序会崩溃.”
    这一句与上面提到的“下游收到onError事件之后将不再继续接收事件”有矛盾。作者想表达的是不是“发送多个onError,就会导致崩溃”?
    同时,“调用dispose()并不会导致上游不再继续发送事件, 上游会继续发送剩余的事件.”,怎样才能正确的让上游停止发送剩余的事件?例如:上游用interval一直发送事件,当满足某种条件后,如何取消上游事件的发送?

    给初学者的RxJava2.0教程(一)

    Outline [TOC] 前言 上个月RxJava2正式版发布了,但目前国内的资料还比较少,以前使用过RxJava1只需要看看更新文档就知道怎么使用了,但还有一些以前没用过...