RxJS - 實用運算子 subscribeOn

此運算子有助於根據作為輸入獲取的排程程式非同步訂閱源可觀察物件。

語法

subscribeOn(scheduler): Observable

引數

排程程式 − 排程程式用作幫助重新發射源可觀察物件通知的輸入。

返回值

它將返回一個可觀察物件，與源可觀察物件相同，但使用排程程式引數。

示例

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

let test1 = of(2, 4, 6, 8).pipe(subscribeOn(asyncScheduler));
let test2 = of(3, 6, 9, 12, 15);
let sub1 = merge(test1, test2).subscribe(console.log);

輸出