InnerSubscriber.js 745 B

123456789101112131415161718192021222324252627
  1. import { Subscriber } from './Subscriber';
  2. /**
  3. * We need this JSDoc comment for affecting ESDoc.
  4. * @ignore
  5. * @extends {Ignored}
  6. */
  7. export class InnerSubscriber extends Subscriber {
  8. constructor(parent, outerValue, outerIndex) {
  9. super();
  10. this.parent = parent;
  11. this.outerValue = outerValue;
  12. this.outerIndex = outerIndex;
  13. this.index = 0;
  14. }
  15. _next(value) {
  16. this.parent.notifyNext(this.outerValue, value, this.outerIndex, this.index++, this);
  17. }
  18. _error(error) {
  19. this.parent.notifyError(error, this);
  20. this.unsubscribe();
  21. }
  22. _complete() {
  23. this.parent.notifyComplete(this);
  24. this.unsubscribe();
  25. }
  26. }
  27. //# sourceMappingURL=InnerSubscriber.js.map