RxJS：公用程序操作符subscriptionOn

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

句法

subscribeOn(scheduler): Observable

参量

scheduler – 有助于从可观察的源重新发送通知。

返回值

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

输出：3 6 9 12 15 2 4 6 8