首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    RxJava && Agera 从源码简要分析基本调用流程(2)

    同样也是基于观察者模式,Agera和RxJava的角色分类大致相似,在Agera中,主要角色有两个:Observable(被观察者)、Updatable(观察者)。...若一个Updatable观察了此Reservoir,其队列中发生调度变化后即将出列的下一个数据如果是可用的(非空),就会通知该Updatable,进一步拉取这个数据发送给Receiver。...返回RTermination orSkip() 若前面的操作检查为失败,就跳过剩下的数据处理流,并且不会通知所有已添加的Updatable。...再回到上面的示例代码: [image.jpg] 我们在onResume()、onPause()这两个生命周期下分别添加、移除了Updatable。...我们根据需要添加Updatable,repository在数据流处理完成后会通过update()发送event通知Updatable

    10.4K10

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    活动推荐

      运营活动

      活动名称
      广告关闭
      领券