Scheduler.async的RxJS依赖问题

Question

我在Angular2组件类的构造函数中有以下代码：

var observable = Observable.create(function (observer) {
      observer.next(1);
      observer.next(2);
      observer.next(3);
      observer.complete();
    }).observeOn(Scheduler.async);

我导入包括以下内容：

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/observeOn';
import { Scheduler } from 'rxjs/Scheduler';
import 'rxjs/scheduler/async';

我也尝试了以下导入，而不是上面的上一次导入：

import { async } from 'rxjs/scheduler/async';

使用Angular CLI构建项目时出现以下错误消息：

Property 'async' does not exist on type 'typeof Scheduler'

我错过了什么？

Answer 1

是的，这是正确的，因为：

import { Scheduler } from 'rxjs/Scheduler';

这意味着，您导入了这个类：https://github.com/ReactiveX/rxjs/blob/5.4.0/src/Scheduler.ts#L8-L63

和

import { async } from 'rxjs/scheduler/async';

是https://github.com/ReactiveX/rxjs/blob/5.4.0/src/scheduler/async.ts#L47

所以你可以看到，Scheduler没有async属性，我想你想转换这个东西Rx.Scheduler.async source code here，你可以试试这个解决方案：

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/observeOn';

import { async } from 'rxjs/scheduler/async';

var observable = Observable.create(function (observer) {
      observer.next(1);
      observer.next(2);
      observer.next(3);
      observer.complete();
    }).observeOn(async);

Answer 2

我认为这应该得到更深入的解释。

如果你只写：

import { Scheduler } from 'rxjs/Scheduler';

你只是导入你可能永远不想自己使用的Scheduler类。导入它仅用于正确的类型检查是有用的，所以你可以有例如：

import { Scheduler } from 'rxjs/Scheduler';

class MyClass {
    sched: Scheduler;
}

但只导入async你导入already existing instance of an AsyncScheduler class。这是一个单例模式，因为通常不需要有多个AsyncScheduler实例。

import { async } from 'rxjs/scheduler/async';

现在您可以查看此特定调度程序的当前时间：

async.now();

实际上从rxjs/scheduler/async进口与使用从Scheduler进口的rxjs相同，实际上是Rx.ts：

import { Scheduler } from 'rxjs';

...

Scheduler.async.now();

您可以看到已经准备了更多不同的调度程序：https://github.com/ReactiveX/rxjs/blob/master/src/Rx.ts#L193-L198

令人困惑的是，使用async的'rxjs/scheduler/async'和Scheduler.async的'rxjs'有什么区别。 The async from Rx.ts just imports the same 'rxjs/scheduler/async'但是因为你导入rxjs你还包括Rx.ts中定义的所有依赖项。这意味着您要导入所有运算符，这些运算符是您可能不需要的大量文件。

这就是为什么最好只从'rxjs/scheduler/async'而不是'rxjs'导入它：

import { async } from 'rxjs/scheduler/async'

Answer 3

我知道这是为typescript，angular和rxjs5标记的，但是如果你在这里登陆并且为什么其他答案不适合你而感到困惑，我认为调度程序的位置在v6中再次移动。我有一个webpack开发环境，我不得不从简单的rxjs模块中获取调度程序。如果检查导入的模块，则可以看到所有调度程序：

import * as rxjs from "rxjs";
console.log(Object.keys(rxjs).filter(k => k.includes("Scheduler")));

将打印：

"asapScheduler"
"asyncScheduler"
"queueScheduler"
"animationFrameScheduler"
"VirtualTimeScheduler"
"Scheduler"

所以如果你想要async Scheduler，你可以这样做：

import {asyncScheduler} from "rxjs";