RxJS subscribeOn

異步地在指定上將 Observable 訂閱此 Observable SchedulerLike。

subscribeOn<T>(scheduler: SchedulerLike, delay: number = 0): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：對源 Observable 進行了修改，使其訂閱發(fā)生在指定的SchedulerLike。。

描述

subscribeOn您可以使用它來確定特定 Observable 訂閱時將使用哪種調(diào)度程序。

調(diào)度程序控制可觀察流向觀察者的發(fā)射速度和順序。

例

給出以下代碼：

import { of, merge } from 'rxjs';


const a = of(1, 2, 3, 4);
const b = of(5, 6, 7, 8, 9);
merge(a, b).subscribe(console.log);

一旦被觀察到a，這兩個 Observable b 都會直接并同步地發(fā)出它們的值。這將導(dǎo)致輸出1 2 3 4 5 6 7 8 9。

但是，如果改為使用subscribeOn運算符，則聲明要使用async發(fā)出的值a：

import { of, merge, asyncScheduler } from 'rxjs';
import { subscribeOn } from 'rxjs/operators';


const a = of(1, 2, 3, 4).pipe(subscribeOn(asyncScheduler));
const b = of(5, 6, 7, 8, 9);
merge(a, b).subscribe(console.log);

輸出將改為5 6 7 8 9 1 2 3 4。這是因為 Observable b 像以前一樣直接且同步地發(fā)出其值，但從a該事件發(fā)出的消息已安排在事件循環(huán)