aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js73
1 files changed, 73 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js
new file mode 100644
index 00000000..29713d05
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/Notification.js
@@ -0,0 +1,73 @@
+import { empty } from './observable/empty';
+import { of } from './observable/of';
+import { throwError } from './observable/throwError';
+export var NotificationKind;
+(function (NotificationKind) {
+ NotificationKind["NEXT"] = "N";
+ NotificationKind["ERROR"] = "E";
+ NotificationKind["COMPLETE"] = "C";
+})(NotificationKind || (NotificationKind = {}));
+export class Notification {
+ constructor(kind, value, error) {
+ this.kind = kind;
+ this.value = value;
+ this.error = error;
+ this.hasValue = kind === 'N';
+ }
+ observe(observer) {
+ switch (this.kind) {
+ case 'N':
+ return observer.next && observer.next(this.value);
+ case 'E':
+ return observer.error && observer.error(this.error);
+ case 'C':
+ return observer.complete && observer.complete();
+ }
+ }
+ do(next, error, complete) {
+ const kind = this.kind;
+ switch (kind) {
+ case 'N':
+ return next && next(this.value);
+ case 'E':
+ return error && error(this.error);
+ case 'C':
+ return complete && complete();
+ }
+ }
+ accept(nextOrObserver, error, complete) {
+ if (nextOrObserver && typeof nextOrObserver.next === 'function') {
+ return this.observe(nextOrObserver);
+ }
+ else {
+ return this.do(nextOrObserver, error, complete);
+ }
+ }
+ toObservable() {
+ const kind = this.kind;
+ switch (kind) {
+ case 'N':
+ return of(this.value);
+ case 'E':
+ return throwError(this.error);
+ case 'C':
+ return empty();
+ }
+ throw new Error('unexpected notification kind value');
+ }
+ static createNext(value) {
+ if (typeof value !== 'undefined') {
+ return new Notification('N', value);
+ }
+ return Notification.undefinedValueNotification;
+ }
+ static createError(err) {
+ return new Notification('E', undefined, err);
+ }
+ static createComplete() {
+ return Notification.completeNotification;
+ }
+}
+Notification.completeNotification = new Notification('C');
+Notification.undefinedValueNotification = new Notification('N', undefined);
+//# sourceMappingURL=Notification.js.map \ No newline at end of file