Home Manual Reference Source Test Repository
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:

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

用来标示该 Subscription 是否被取消订阅的标示位。

public

添加一个 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:

NameTypeAttributeDescription
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:

NameTypeAttributeDescription
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:

NameTypeAttributeDescription
err any
  • optional

error 异常.

Return:

void

public next(value: T): void source

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

Params:

NameTypeAttributeDescription
value T
  • optional

The next value.

Return:

void