可流动,允许在有订阅者/没有订阅者的情况下开始/停止发布

问题描述

我正在尝试使用rxjava2在项目中构建通用模式,该模式将允许两个信号-

  1. 知道第一个订阅者何时订阅
  2. 知道最后一个订阅者何时退订。

最后一个订阅者取消订阅后,Flowable不应终止,从而允许#1和#2再次发生。

一个真正的用例是根据是否有任何订阅者来知道何时需要注册到android服务以及何时可以注销该服务。假定不直接了解UI生命周期。

rxjava2的新手,如果这是一个基本问题,请承担。

到目前为止,我已经找到了一种方法。使用FlowableProcessor并使用doOnSubscribedoFinallyhasSubscribers来获得两个信号,但是,我很好奇这是否是正确的模式或是否存在是更标准的方法。 我看到也有一个ConnectableFlowable,但我不知道如何用它来实现相同的目的。

感谢帮助,谢谢!

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)