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);

输出