问题描述
我正在尝试使用rxjava2在项目中构建通用模式,该模式将允许两个信号-
最后一个订阅者取消订阅后,Flowable不应终止,从而允许#1和#2再次发生。
一个真正的用例是根据是否有任何订阅者来知道何时需要注册到android服务以及何时可以注销该服务。假定不直接了解UI生命周期。
rxjava2的新手,如果这是一个基本问题,请承担。
到目前为止,我已经找到了一种方法。使用FlowableProcessor
并使用doOnSubscribe
,doFinally
和hasSubscribers
来获得两个信号,但是,我很好奇这是否是正确的模式或是否存在是更标准的方法。
我看到也有一个ConnectableFlowable
,但我不知道如何用它来实现相同的目的。
感谢帮助,谢谢!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)