[译]RxJS文档07——Operators 操做符

原文:http://reactivex.io/rxjs/manu...

Operators

RxJS提供的操做符很是有用，尽管Observable是基础对象。
操做符是声明式编程中将复杂的异步代码转变为简单的代码组合的重要措施。

什么是操做符 (operator)？

操做符是Observable类型的一组方法，好比像:.map(...),.filter(...),.merge(...),等等。当方法被调用的时候，他们不会更改已经存在的Observable流实例，而是返回一个新的Observable流的实例，这个新的对象中的订阅逻辑则是创建在第一个Observable流之上的。

一个Operator可以在当前的Observable流基础上建立一个新的Observable流。这是一个纯粹的新处理过程：以前的Observable保持不变。

操做符本质上是可以接收一个Observable流做为输入，并返回一个Observable流做为输出的纯函数。
订阅输出的Observable流也会同时订阅输入的Observable流。
在下面的例子中，咱们建立了一个自定义的操做符函数能够将全部输入的值都乘以10，而后输出：

function multiplyByTen(input) {
  var output = Rx.Observable.create(function subscribe(observer) {
    input.subscribe({
      next: (v) => observer.next(10 * v),
      error: (err) => observer.error(err),
      complete: () => observer.complete()
    });
  });
  return output;
}

var input = Rx.Observable.from([1, 2, 3, 4]);
var output = multiplyByTen(input);
output.subscribe(x => console.log(x));

输出为:

10
20
30
40

注意以上的例子中，订阅输出流也会同时订阅输入流的状况。咱们称这种现象为：“操做符订阅链”。

实例操做符 vs 静态操做符

什么是实例操做符？ 一般说起操做符，咱们假定指的都是实例操做符，他们是Observable流的实例方法。
例如，若是multiplyByTen是正式的实例操做符，他将会是这样的：

Rx.Observable.prototype.multiplyByTen = function multiplyByTen() {
  var input = this;
  return Rx.Observable.create(function subscribe(observer) {
    input.subscribe({
      next: (v) => observer.next(10 * v),
      error: (err) => observer.error(err),
      complete: () => observer.complete()
    });
  });
}

实例操做符本质是一个函数，他在内部使用this关键字指代Observable输入流。

注意输入Observable流已经再也不做为函数的参数，它被假定为this所指向的对象。下面是咱们如何使用实例操做符：

var observable = Rx.Observable.from([1, 2, 3, 4]).multiplyByTen();

observable.subscribe(x => console.log(x));

什么是静态操做符？ 有别于实例操做符，静态操做符直接是Observable类的方法。静态操做符函数内部再也不使用this，它彻底依赖函数的参数。

静态操做符是依赖于Observable类的一组纯函数，一般被用来从头建立Observable流。

最多见的静态操做符类型是所谓的建立操做符。不一样于将输入流转换成输出流的操做符，他们不用接收Observable类型的参数，而是接收诸如number类型的参数，就能够建立一道数据流。

一个经典的例子是使用静态操做符interval()。他接收一个数字(而不是Observable流)做为输入参数，以后产生一道Observable流做为输出：

var observable = Rx.Observable.interval(1000 /* number of milliseconds */);

另外一个建立操做符的例子是create()，在以前的例子里已经用了不少次。你能够从这里查看全部的建立操做符。

然而，静态操做符们并不只限于简单建立。一些组合操做符也是静态的，例如merage,combineLates,concat等等。他们能够整合多道输入的Observable流，因此也是很是有意义的静态操做符。

var observable1 = Rx.Observable.interval(1000);
var observable2 = Rx.Observable.interval(400);

var merged = Rx.Observable.merge(observable1, observable2);

珠宝图 Marble diagrams

为了更好的展现操做符是如何工做的，只有文字性的解释是不够的。不少操做符依赖于时间，例如他们可能会使用延迟，取样，节流，又或者去抖等等方式。
画一些图表能很好的说明这些过程。珠宝图就是用来展现这些的图表，他包含输入Observable流，操做符和相关参数，还有输出流。

在珠宝图中，时间的流逝被标为从左到右的水平线，线上的每一个值(“珠宝”)表明了Observable流在执行过程当中发出的值。

下图你能够看到对珠宝的详解。

贯穿本站的文档，咱们会普遍的使用珠宝图去解释操做符是如何生效的。在别的场景下他们或许一样有用，例如在whiteboard上或者在单元测试中(做为ASCII图表)。