Home Manual Reference Source Test Repository
import {SubjectSubscriber} from '@reactivex/rxjs/es6/Subject.js'
public class | source

SubjectSubscriber

Extends:

SubscriptionSubscriber → SubjectSubscriber

Direct Subclass:

es6/observable/ConnectableObservable.js~ConnectableSubscriber

Inherited Summary

From class Subscription
public

A flag to indicate whether this Subscription has already been unsubscribed.

public

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.