ConnectableObservable.d.ts 907 B

1234567891011121314151617181920212223
  1. import { Subject } from '../Subject';
  2. import { Observable } from '../Observable';
  3. import { Subscriber } from '../Subscriber';
  4. import { Subscription } from '../Subscription';
  5. /**
  6. * @class ConnectableObservable<T>
  7. */
  8. export declare class ConnectableObservable<T> extends Observable<T> {
  9. source: Observable<T>;
  10. protected subjectFactory: () => Subject<T>;
  11. protected _subject: Subject<T>;
  12. protected _refCount: number;
  13. protected _connection: Subscription;
  14. /** @internal */
  15. _isComplete: boolean;
  16. constructor(source: Observable<T>, subjectFactory: () => Subject<T>);
  17. /** @deprecated This is an internal implementation detail, do not use. */
  18. _subscribe(subscriber: Subscriber<T>): Subscription;
  19. protected getSubject(): Subject<T>;
  20. connect(): Subscription;
  21. refCount(): Observable<T>;
  22. }
  23. export declare const connectableObservableDescriptor: PropertyDescriptorMap;