RxJS - 实用运算符 subscribeOn

此运算符有助于根据作为输入的调度程序异步订阅源 Observable。

语法

subscribeOn(scheduler): Observable

参数

scheduler − 调度程序用作输入，有助于重新发出来自源 Observable 的通知。

返回值

它将返回与源 Observable 相同的 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);

输出