import { Operator } from './Operator'; import { Observer } from './Observer'; import { Observable } from './Observable'; import { Subscriber } from './Subscriber'; import { ISubscription, Subscription, TeardownLogic } from './Subscription'; /** * @class SubjectSubscriber */ export declare class SubjectSubscriber extends Subscriber { protected destination: Subject; constructor(destination: Subject); } /** * @class Subject */ export declare class Subject extends Observable implements ISubscription { observers: Observer[]; closed: boolean; isStopped: boolean; hasError: boolean; thrownError: any; constructor(); static create: Function; lift(operator: Operator): Observable; next(value?: T): void; error(err: any): void; complete(): void; unsubscribe(): void; protected _trySubscribe(subscriber: Subscriber): TeardownLogic; /** @deprecated internal use only */ _subscribe(subscriber: Subscriber): Subscription; asObservable(): Observable; } /** * @class AnonymousSubject */ export declare class AnonymousSubject extends Subject { protected destination: Observer; constructor(destination?: Observer, source?: Observable); next(value: T): void; error(err: any): void; complete(): void; /** @deprecated internal use only */ _subscribe(subscriber: Subscriber): Subscription; }