12345678910111213141516171819202122 |
- import { Subject } from '../Subject';
- import { Observable } from '../Observable';
- import { Subscriber } from '../Subscriber';
- import { Subscription } from '../Subscription';
- export declare class ConnectableObservable<T> extends Observable<T> {
- source: Observable<T>;
- subjectFactory: () => Subject<T>;
- _subject: Subject<T>;
- _refCount: number;
- _connection: Subscription;
- _isComplete: boolean;
- constructor( source: Observable<T>,
- subjectFactory: () => Subject<T>);
- _subscribe(subscriber: Subscriber<T>): Subscription;
- getSubject(): Subject<T>;
- connect(): Subscription;
- refCount(): Observable<T>;
- }
- export declare const connectableObservableDescriptor: PropertyDescriptorMap;
|