rx-java – share()和publish().autoConnect()之间有什么区别？
发布时间：2020-12-15 04:48:25 所属栏目：Java 来源：网络整理
导读：根据我的观点.I thinkhare()与发布().autoConnect()是一样的.但在这段代码中结果不一样 ObservableInteger cold = Observable.create(subscriber - { for (int i = 0; i = 2; i++) { System.out.println("Hot Observable Emit " + i); subscriber.onNext(i);
|
根据我的观点.I thinkhare()与发布().autoConnect()是一样的.但在这段代码中结果不一样
Observable<Integer> cold = Observable.create(subscriber -> {
for (int i = 0; i <= 2; i++) {
System.out.println("Hot Observable Emit " + i);
subscriber.onNext(i);
}
});
ConnectableObservable<Integer> connectble = cold.publish().autoConnect(2);
//Obserable(Integer) connectavle = cold.share();
connectble.subscribe(subscriber1);
connectble.subscribe(subscriber2);
publish(). autoConnect()输出 Hot Observable Emit 0 Subscriber 1 : 0 Subscriber 2 : 0 .... share()输出 Hot Observable Emit 0 Subscriber 1 : 0 //the subscriber2 not receive event 在这种情况下,我们不能在rx-java中使用share()进行多播？我发现conclusion但不适合这种情况. 测试环境：oracle jdk1.8 rx-java 1.2 IDEA ubuntu 解决方法
它们的不同之处在于,当订户取消订阅共享时,上游断开连接,当新订户订阅时,上游源重新订阅并从头开始(如果冷).
autoConnect等待指定数量的订户,连接一次,并且在所有订户取消订阅时永不断开连接.这是关于它是如何工作的description. （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |