RxJS Angular 2 语法

Question

我目前正在阅读 RxJS 库，并花一些时间阅读它的一些架构师和贡献者提供的一些课程，目的是将这些知识整合到 angular2 应用程序中。我发现这很困难，因为我似乎无法弄清楚如何更改语法，所以我可以使用 RxJS，就像我在任何不是 angular2 特定的示例中看到的那样。例如，如果我尝试在构造函数中创建观察者：

this.$mouseObserver = Rx.Observer.create(
      function (x) {
     console.log('Next: %s', x);
   },
   function (err) {
     console.log('Error: %s', err);
   },
   function () {
     console.log('Completed');
   });

Rx 总是出现未定义，即使在导入之后也是如此。 Observer 和 Observable 导入很好，以及它们的方法。我错过了一些基本的东西吗？ RxJS 的每篇文档几乎都以 Rx. 开头，但我还没有看到使用该语法的单个 Angular 2 教程。

Answer 1

如果你：

import { Observer } from 'rxjs/Observer';

或：

import { Observer } from 'rxjs/Rx';

您将使用Observer.create（没有 Rx。）。要使用Rx.Observer，您需要import * as Rx from 'rxjs/Rx';

通常首选导入单个类/对象，这就是为什么您会看到更多该表单的导入。 Rx. 表单通常出现在没有导入 Rx 库的地方（例如，项目不是内置在 node 环境中），而是从 <script src="..."> 标记引用

编辑：回答 C. Kearns 的评论：

Observer，在 RxJS 5 类型定义中，是一个接口。它没有实现，也没有编译成 javascript。因此你不能调用它的任何函数。接口声明为：

export interface Observer<T> {
    isUnsubscribed?: boolean;
    next: (value: T) => void;
    error: (err: any) => void;
    complete: () => void;
}

在您的情况下，将$mouseObserver 声明为Observer<any>，这应该可以：

this.$mouseObserver = {
  next: function (x) {
    console.log('Next: %s', x);
  },
  error: function (err) {
    console.log('Error: %s', err);
  },
  complete: function () {
    console.log('Completed');
  }
};