blob: fe3a8e861310c9371c02db81e3334d204f208e43 [file] [log] [blame]
import { Subject } from '../Subject';
import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
/**
* @class ConnectableObservable<T>
*/
export declare class ConnectableObservable<T> extends Observable<T> {
source: Observable<T>;
protected subjectFactory: () => Subject<T>;
protected _subject: Subject<T>;
protected _refCount: number;
protected _connection: Subscription;
/** @internal */
_isComplete: boolean;
constructor(source: Observable<T>, subjectFactory: () => Subject<T>);
/** @deprecated This is an internal implementation detail, do not use. */
_subscribe(subscriber: Subscriber<T>): Subscription;
protected getSubject(): Subject<T>;
connect(): Subscription;
refCount(): Observable<T>;
}
export declare const connectableObservableDescriptor: PropertyDescriptorMap;