AsyncSubject.d.ts 640 B

1234567891011121314151617181920
  1. import { Subject } from './Subject';
  2. import { Subscriber } from './Subscriber';
  3. import { Subscription } from './Subscription';
  4. /**
  5. * A variant of Subject that only emits a value when it completes. It will emit
  6. * its latest value to all its observers on completion.
  7. *
  8. * @class AsyncSubject<T>
  9. */
  10. export declare class AsyncSubject<T> extends Subject<T> {
  11. private value;
  12. private hasNext;
  13. private hasCompleted;
  14. /** @deprecated This is an internal implementation detail, do not use. */
  15. _subscribe(subscriber: Subscriber<any>): Subscription;
  16. next(value: T): void;
  17. error(error: any): void;
  18. complete(): void;
  19. }