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;
|
