RxJS defer

創(chuàng)建一個(gè) Observable，在訂閱時(shí)，該 Observable 調(diào)用一個(gè) Observable 工廠(chǎng)以為每個(gè)新的 Observer 創(chuàng)建 Observable。

defer<R extends ObservableInput<any> | void>(observableFactory: () => R): Observable<ObservedValueOf<R>>

參量

returns

Observable<ObservedValueOf<R>>：一個(gè) Observable，其 Observers 的訂閱觸發(fā)對(duì)給定 Observable 工廠(chǎng)函數(shù)的調(diào)用。

描述

延遲創(chuàng)建 Observable，即僅在訂閱時(shí)創(chuàng)建。

defer允許您僅在觀(guān)察者訂閱時(shí)創(chuàng)建觀(guān)察者，并為每個(gè)觀(guān)察者創(chuàng)建一個(gè)新的觀(guān)察者。它等待，直到觀(guān)察者訂閱它，然后它生成一個(gè)觀(guān)察者，通常帶有觀(guān)察者工廠(chǎng)功能。它為每個(gè)訂閱用戶(hù)重新進(jìn)行此操作，因此盡管每個(gè)訂閱用戶(hù)可能認(rèn)為自己正在訂閱相同的 Observable，但實(shí)際上每個(gè)訂閱用戶(hù)都擁有自己的個(gè)人 Observable。

例

隨機(jī)訂閱可觀(guān)察的點(diǎn)擊或間隔的觀(guān)察

import { defer, fromEvent, interval } from 'rxjs';


const clicksOrInterval = defer(function () {
  return Math.random() > 0.5
    ? fromEvent(document, 'click')
    : interval(1000);
});
clicksOrInterval.subscribe(x => console.log(x));


// Results in the following behavior:
// If the result of Math.random() is greater than 0.5 it will listen
// for clicks anywhere on the "document"; when document is clicked it
// will log a MouseEvent object to the console. If the result is less
// than 0.5 it will emit ascending numbers, one every second(1000ms).

也可以看看

• Observable