javascript - rxjs中publishReplay().refCount()的作用
本文介绍了javascript - rxjs中publishReplay().refCount()的作用的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
问 题
我找了很多资料都看的不是很明白,希望大家可以简单的说一说或者提供点资料,谢谢!
解决方案
var subject$$ = new Rx.ReplaySubject();
subject$$.subscribe( x => console.log('sub',x) );
var observableA$ = Rx.Observable.of('test');
observableA$.subscribe(subject$$) ;
=======省略的写法========
var connectableObservable$ = Rx.Observable.of('test').multicast( new Rx.ReplaySubject())
//需要手动的去connect
var sub = connectableObservable$.connect();
connectableObservable$.subscribe( x => console.log('sub',x) );
//需要手动去unsubscribe unconnect
sub.unsubscribe()
=====这样很麻烦,使用引用计数 来自动connect unconnect====
var sourceA$ = connectableObservable$.refCount(); //stands for referenceCounting
var subA = sourceA$.subscribe( x => console.log('sub',x) )
//ref 0->1 then automatic connect
subA.unsubscribe()
//ref 1-> 0 then automatic unconnect
Rx.Observable.of('test').multicast( new Rx.ReplaySubject() ).refCount()
->进一步省略
Rx.Observable.of('test').publishReplay().refCount()
这篇关于javascript - rxjs中publishReplay().refCount()的作用的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文