RxJS refCount

使 ConnectableObservable行為像普通的可觀察對象，并自動連接它。

refCount<T>(): MonoTypeOperatorFunction<T>

參量

沒有參數(shù)。

returns

MonoTypeOperatorFunction<T>

描述

在內(nèi)部，它計算對可觀察對象的訂閱，如果訂閱數(shù)大于0，則訂閱源（僅一次）。如果訂閱數(shù)小于1，則取消訂閱源。這樣，您可以確保發(fā)布的 refCount 之前的所有內(nèi)容僅具有單個訂閱，而與目標可觀察者的訂閱者數(shù)量無關。

請注意，使用 share運算符與按順序使用 publish 運算符（使可觀察的熱點）和 refCount 運算符完全相同。

例

在下面的示例中，使用 publish 運算符將兩個間隔變?yōu)榭蛇B接的可觀察對象。第一個使用 refCount 運算符，第二個不使用它。您會注意到，可連接可觀察對象在調(diào)用其連接函數(shù)之前不會執(zhí)行任何操作。

import { interval } from 'rxjs';
import { tap, publish, refCount } from 'rxjs/operators';


// Turn the interval observable into a ConnectableObservable (hot)
const refCountInterval = interval(400).pipe(
  tap((num) => console.log(`refCount ${num}`)),
  publish(),
  refCount()
);


const publishedInterval = interval(400).pipe(
  tap((num) => console.log(`publish ${num}`)),
  publish()
);


refCountInterval.subscribe();
refCountInterval.subscribe();
// 'refCount 0' -----> 'refCount 1' -----> etc
// All subscriptions will receive the same value and the tap (and
// every other operator) before the publish operator will be executed
// only once per event independently of the number of subscriptions.


publishedInterval.subscribe();
// Nothing happens until you call .connect() on the observable.

也可以看看

• ConnectableObservable
• share
• publish