import {Subscriber} from '@reactivex/rxjs/es6/Subscriber.js'

public class | source

Subscriber

Extends:

Subscription → Subscriber

Direct Subclass:

es6/observable/ConnectableObservable.js~RefCountSubscriber, es6/operator/sequenceEqual.js~SequenceEqualCompareToSubscriber, SubjectSubscriber, es6/operator/timestamp.js~TimestampSubscriber

Indirect Subclass:

es6/observable/ConnectableObservable.js~ConnectableSubscriber

实现 Observer 接口并且继承 Subscription 类。虽然 Observer 是消费 Observable 值的公有 API, 所有 Observers 都转化成了 Subscriber，以便提供类似 Subscription 的能力，比如 unsubscribe。 Subscriber 是 RxJS 的常见类型, 并且是实现操作符的关键, 但是很少作为公有 API 使用。

Test:

Subscriber

Static Method Summary

Static Public Methods
public static	create(next: function(x: ?T): void, error: function(e: ?any): void, complete: function(): void): Subscriber<T> Subscriber 的静态工厂，给定了 Observer （潜在的部分）的定义。

Constructor Summary

Public Constructor
public	constructor(destinationOrNext: Observer \| function(value: T): void, error: function(e: ?any): void, complete: function(): void)

Method Summary

Public Methods
public	complete(): void Observer 的回调，用来接收 Observable 中的 `complete` 类型通知。通知 Observer， Observable 完成了基于推送体系的通知。
public	error(err: any): void Observer 的回调，用来接收 Observable 中的 error 类型通知，此通知带有 Error 。通知 Observer，Observable 发出了错误。
public	next(value: T): void Observer 的回调，用来接收 Observable 中的 next 类型通知，此通知带有值。 Observable 可能会掉用这个方法 0 次，或者多次。

Inherited Summary

From class Subscription
public	closed: boolean 用来标示该 Subscription 是否被取消订阅的标示位。
public	add(teardown: TeardownLogic): Subscription 添加一个 tear down 在该 Subscription 的 unsubscribe() 期间调用。
public	remove(subscription: Subscription): void 从 Subscription 的内部列表中删除一个 Subscription。在该 Subscription 取消订阅的过程中取消订阅。
public	unsubscribe(): void 清理 subscription 持有的资源。例如，可以取消正在进行的 Observable 执行或取消在创建 Subscription 时启动的任何其他类型的工作。

Static Public Methods

public static create(next: function(x: ?T): void, error: function(e: ?any): void, complete: function(): void): Subscriber<T> source

Subscriber 的静态工厂，给定了 Observer （潜在的部分）的定义。

Params:

Name	Type	Attribute	Description
next	function(x: ?T): void	optional	Observer 的 `next` 回调函数。
error	function(e: ?any): void	optional	Observer 的 `error` 回调函数。
complete	function(): void	optional	Observer 的 `complete` 回调函数。

Return:

Subscriber<T>

包装了作为参数传入的（部分定义）Observer 的 Subscriber。

Public Constructors

public constructor(destinationOrNext: Observer | function(value: T): void, error: function(e: ?any): void, complete: function(): void) source

Override:

Subscription#constructor

Params:

Name	Type	Attribute	Description
destinationOrNext	Observer \| function(value: T): void	optional	部分定义的 Observer 或者 `next` 回调函数。
error	function(e: ?any): void	optional	Observer 的 `error` 回调函数。
complete	function(): void	optional	Observer 的 `complete` 回调函数。

Public Methods

public complete(): void source

Observer 的回调，用来接收 Observable 中的 complete 类型通知。通知 Observer， Observable 完成了基于推送体系的通知。

Return:

void

public error(err: any): void source

Observer 的回调，用来接收 Observable 中的 error 类型通知，此通知带有 Error 。通知 Observer，Observable 发出了错误。

Params:

Name	Type	Attribute	Description
err	any	optional	`error` 异常.

Return:

void

public next(value: T): void source

Observer 的回调，用来接收 Observable 中的 next 类型通知，此通知带有值。 Observable 可能会掉用这个方法 0 次，或者多次。

Params:

Name	Type	Attribute	Description
value	T	optional	The `next` value.

Return:

void