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 A flag to indicate whether this Subscription has already been unsubscribed.
public	add(teardown: TeardownLogic): Subscription Adds a tear down to be called during the unsubscribe() of this Subscription.
public	remove(subscription: Subscription): void Removes a Subscription from the internal list of subscriptions that will unsubscribe during the unsubscribe process of this Subscription.
public	unsubscribe(): void Disposes the resources held by the subscription.

From class Subscriber
public static	create(next: function(x: ?T): void, error: function(e: ?any): void, complete: function(): void): Subscriber<T> A static factory for a Subscriber, given a (potentially partial) definition of an Observer.
public	complete(): void The Observer callback to receive a valueless notification of type `complete` from the Observable.
public	error(err: any): void The Observer callback to receive notifications of type `error` from the Observable, with an attached Error.
public	next(value: T): void The Observer callback to receive notifications of type `next` from the Observable, with a value.