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

public class | source

SubjectSubscriber

Subscription → Subscriber → SubjectSubscriber

es6/observable/ConnectableObservable.js~ConnectableSubscriber

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 时启动的任何其他类型的工作。

From class Subscriber
public static	create(next: function(x: ?T): void, error: function(e: ?any): void, complete: function(): void): Subscriber<T> Subscriber 的静态工厂，给定了 Observer （潜在的部分）的定义。
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 次，或者多次。