RXJS----Operators操作符

2017-03-24

RxJS如此强大的原因正是源自于它的操作符，即便可观察对象扮演着根基的角色。操作符使得复杂的异步代码轻松的以声明的方式容易地组成。

什么是操作符？

操作符是可观察对象上定义的方法，例如.map(…),.filter(…),.merge(…)，等等。当他们被调用，并不会去改变当前存在的可观察对象实例。相反，他们返回一个新的可观察对象，而且新返回的subscription订阅对象逻辑上基于调用他们的观察对象。

每一个操作符都是基于当前可观察对象创建一个新的可观察对象的函数。这是一个单纯无害的操作:之前的可观察对象仍然保持不变。

一个操作符本质上是一个将某个可观察对象作为输入然后输出另一个可观察对象的纯函数。对输出的新的可观察对象进行订阅的同时也会订阅作为输入的那个可观察对象。下面的例子，我们创建一个自定义的运算符函数，将从作为输入的可观察对象的每个值乘以10.

function multiplyByTen(input) {
  var output =Rx.Observable.create(function(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));

输出如下:

注意一下我们对output的订阅导致了作为输入的可观察对象也被订阅了。我们称这种现象为”操作符的订阅链”。

实例操作符(instance operator)VS静态操作符(static operator)

什么是实例操作符？通常，当引用运算符，我们假设是来自可观察对象实例的运算符。作为示例，如果multiplyByTen一个官方库中的操作符，那它大概是下面的样子:

Rx.Observable.prototype.multiplyByTen = function(){
  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()
    });
  });
}

译者注:考虑到可能会有些刚接触的人不太理解。上面的代码是这样的，操作符定义在可观察对象的原型对象上，如果某个可观察对象调用这个方法，input首先取得作为输入的该可观察对象的引用(后面会在闭包里用到)，然后该方法返回一个由create方法创建的可观察对象，也就是作为输出的可观察对象。而input.subscribe({…})是对input进行订阅。

实例操作符是使用this关键词来推演出”输入可观察对象”是神马东东

注意input并不是作为函数的参数，而是作为this所指代的那个对象。下面是我们如何使用这个操作符:

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

什么是静态操作符？不同于实力操作符，静态操作符是直接定义在类上的。一个静态操作符并不在其内部使用this，而是完全依赖于它的参数。

静态操作符是定义在类上的函数，通常被用于从头重新创建一个可观察对象。

最常规的静态操作符是被称作构造操作符(Creation Operators，原谅我如此翻译，总是隐隐觉得很合适~)。不同于将一个输入的可观察对象转换成一个输出的可观察对象，它们仅接收一个非可观察对象作为参数，比如一个数字，然后构造出一个可观察对象。
一个静态操作符的典型例子是interval函数。它接收一个数字(而不是一个可观察对象)作为输入的参数，然后到一个可观察对象作为输出。

1	var observable = Rx.Observable.intervable(1000)//1000毫秒

另一个构造操作符是create,我们在之前的例子中曾大量使用，一些合并操作符可能是静态的，例如:merge,combineLatest,concat,等等。将这些操作符声明为静态的是有意义的，因为他们接收多个可观察对象作为参数，而不是一个，示例如下:

1
2
3

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

Marble diagrams弹珠图标

使用文字来形容操作符到底是怎样得工作模式终究还是有那么点力不从心。许多的操作符是和时间线密不可分的，在实际中他们可能需要对值进行延迟、采样、节流、或者抖动的发射。使用图表通常能够对他们的过程进行更好的表述。弹珠图标能够囊括作为输入的可观察对象、操作符、及其参数、作为输出的可观察对象来对操作符的工作方式进行生动的表示。

在一个弹珠图标中，时间流向右侧，操作符描述了值(弹珠)在可观察对象执行时被怎样的发射。
下图你可以看到对整个弹珠图表流程的分析。

[ alt ]

贯穿此后的文档，我们将会广泛的使用大理石图标来解释操作的工作过程。他们在其它的内容的表述上也是如此的的有用,例如在一个白板或者我们的单元测试中。

Creation Operators	描述
ajax
bindCallback	public static bindCallback(func: function, selector: function, scheduler: Scheduler) 将一个回调函数API转化为一个能返回一个Observable的函数
bindNodeCallback
create
defer
empty	创建一个不发射任何值的Observable,它只会发射一个complate通知。
from	public static from(ish: ObservableInput, scheduler: Scheduler): Observable ObservableInput A subscribable object, a Promise, an Observable-like, an Array, an iterable or an array-like object to be converted. eg: Rx.Observable.from([1,2,3]);
fromEvent	Rx.Observable.fromEvent(element, eventName, [selector]) 将一个元素上的事件转化为一个Observable eg: var clicks = Rx.Observable.fromEvent(document, ‘click’);
fromEventPattern
fromPromise
generate
interval	public static interval(period: number, scheduler: Scheduler): Observable interval返回一个Observable，它发出一个递增的无限整数序列。
never	创建一个不发射任何值的Observable，它可以用于测试或与其他Observable组合。
of	创建一个Observable，发射指定参数的值，一个接一个，最后发出complate。
repeat
repeatWhen
range	public static range(start:number,count:number,scheduler:Scheduler):Observable range按顺序发出一系列连续整数，参数分别为起点和长度(注意不是终点)。
throw	public static throw(error:any,scheduler:Scheduler):Observable 创建一个只发出error通知的Observable。
timer	public static timer(initialDelay:number or Date,period:number,schedulaer):Observable 类似于interval,但是第一个参数用来设置发射第一个值得延迟时间

Transformation Operators	描述
buffer
bufferCount
bufferTime
bufferToggle
bufferWhen
concatMap
concatMapTo
exhaustMap
expand
groupBy
map
mapTo
mergeMap
mergeMapTo
mergeScan
pairwise
partition
pluck
scan
switchMap
switchMapTo
window
windowCount
windowTime
windowToggle
windowWhen

Filtering Operators	描述
debounce
debounceTime
distinct
distinctKey
distinctUntilChanged
distinctUntilKeyChanged
elementAt
filter
first
ignoreElements
audit
auditTime
last
sample
sampleTime
single
skip
skipUntil
skipWhile
take
takeLast
takeUntil
takeWhile
throttle
throttleTime

Combination Operators	描述
combineAll
combineLatest
concat
concatAll
exhaust
forkJoin
merge
mergeAll
race
startWith
switch
withLatestFrom
zip
zipAll

Multicasting Operators	描述
cache
multicast
publish
publishBehavior
publishLast
publishReplay
share

Error Handling Operators	描述
catch
retry
retryWhen

Utility Operators	描述
do
delay
delayWhen
dematerialize
finally
let
materialize
observeOn
subscribeOn
timeInterval
timestamp
timeout
timeoutWith
toArray
toPromise

Conditional and Boolean Operators	描述
defaultIfEmpty
every
find
findIndex
isEmpty

Mathematical and Aggregate Operators	描述
count
max
min
reduce