.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/Notification.js

   1 import { empty } from './observable/empty';
   2 import { of } from './observable/of';
   3 import { throwError } from './observable/throwError';
   4 export var NotificationKind;
   5 (function (NotificationKind) {
   6     NotificationKind["NEXT"] = "N";
   7     NotificationKind["ERROR"] = "E";
   8     NotificationKind["COMPLETE"] = "C";
   9 })(NotificationKind || (NotificationKind = {}));
  10 export class Notification {
  11     constructor(kind, value, error) {
  12         this.kind = kind;
  13         this.value = value;
  14         this.error = error;
  15         this.hasValue = kind === 'N';
  16     }
  17     observe(observer) {
  18         switch (this.kind) {
  19             case 'N':
  20                 return observer.next && observer.next(this.value);
  21             case 'E':
  22                 return observer.error && observer.error(this.error);
  23             case 'C':
  24                 return observer.complete && observer.complete();
  25         }
  26     }
  27     do(next, error, complete) {
  28         const kind = this.kind;
  29         switch (kind) {
  30             case 'N':
  31                 return next && next(this.value);
  32             case 'E':
  33                 return error && error(this.error);
  34             case 'C':
  35                 return complete && complete();
  36         }
  37     }
  38     accept(nextOrObserver, error, complete) {
  39         if (nextOrObserver && typeof nextOrObserver.next === 'function') {
  40             return this.observe(nextOrObserver);
  41         }
  42         else {
  43             return this.do(nextOrObserver, error, complete);
  44         }
  45     }
  46     toObservable() {
  47         const kind = this.kind;
  48         switch (kind) {
  49             case 'N':
  50                 return of(this.value);
  51             case 'E':
  52                 return throwError(this.error);
  53             case 'C':
  54                 return empty();
  55         }
  56         throw new Error('unexpected notification kind value');
  57     }
  58     static createNext(value) {
  59         if (typeof value !== 'undefined') {
  60             return new Notification('N', value);
  61         }
  62         return Notification.undefinedValueNotification;
  63     }
  64     static createError(err) {
  65         return new Notification('E', undefined, err);
  66     }
  67     static createComplete() {
  68         return Notification.completeNotification;
  69     }
  70 }
  71 Notification.completeNotification = new Notification('C');
  72 Notification.undefinedValueNotification = new Notification('N', undefined);
  73 //# sourceMappingURL=Notification.js.map