import { Operator } from './Operator'; import { Observable } from './Observable'; import { Observer, SubscriptionLike } from './types'; /** * A Subject is a special type of Observable that allows values to be * multicasted to many Observers. Subjects are like EventEmitters. * * Every Subject is an Observable and an Observer. You can subscribe to a * Subject, and you can call next to feed values as well as error and complete. */ export declare class Subject extends Observable implements SubscriptionLike { closed: boolean; private currentObservers; /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ observers: Observer[]; /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ isStopped: boolean; /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ hasError: boolean; /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ thrownError: any; /** * Creates a "subject" by basically gluing an observer to an observable. * * @nocollapse * @deprecated Recommended you do not use. Will be removed at some point in the future. Plans for replacement still under discussion. */ static create: (...args: any[]) => any; constructor(); /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ lift(operator: Operator): Observable; next(value: T): void; error(err: any): void; complete(): void; unsubscribe(): void; get observed(): boolean; /** * Creates a new Observable with this Subject as the source. You can do this * to create custom Observer-side logic of the Subject and conceal it from * code that uses the Observable. * @return {Observable} Observable that the Subject casts to */ asObservable(): Observable; } /** * @class AnonymousSubject */ export declare class AnonymousSubject extends Subject { /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ destination?: Observer | undefined; constructor( /** @deprecated Internal implementation detail, do not use directly. Will be made internal in v8. */ destination?: Observer | undefined, source?: Observable); next(value: T): void; error(err: any): void; complete(): void; } //# sourceMappingURL=Subject.d.ts.map