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
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
observable | Folder | 0755 |
|
|
operators | Folder | 0755 |
|
|
scheduled | Folder | 0755 |
|
|
scheduler | Folder | 0755 |
|
|
symbol | Folder | 0755 |
|
|
testing | Folder | 0755 |
|
|
util | Folder | 0755 |
|
|
AsyncSubject.js | File | 1.07 KB | 0644 |
|
AsyncSubject.js.map | File | 1.1 KB | 0644 |
|
BehaviorSubject.js | File | 876 B | 0644 |
|
BehaviorSubject.js.map | File | 875 B | 0644 |
|
InnerSubscriber.js | File | 653 B | 0644 |
|
InnerSubscriber.js.map | File | 751 B | 0644 |
|
Notification.js | File | 2.31 KB | 0644 |
|
Notification.js.map | File | 2.13 KB | 0644 |
|
Observable.js | File | 3.23 KB | 0644 |
|
Observable.js.map | File | 3.05 KB | 0644 |
|
Observer.js | File | 389 B | 0644 |
|
Observer.js.map | File | 433 B | 0644 |
|
Operator.js | File | 36 B | 0644 |
|
Operator.js.map | File | 105 B | 0644 |
|
OuterSubscriber.js | File | 416 B | 0644 |
|
OuterSubscriber.js.map | File | 489 B | 0644 |
|
ReplaySubject.js | File | 3.57 KB | 0644 |
|
ReplaySubject.js.map | File | 3.44 KB | 0644 |
|
Rx.js | File | 7.4 KB | 0644 |
|
Rx.js.map | File | 4.45 KB | 0644 |
|
Scheduler.js | File | 353 B | 0644 |
|
Scheduler.js.map | File | 459 B | 0644 |
|
Subject.js | File | 4.03 KB | 0644 |
|
Subject.js.map | File | 3.94 KB | 0644 |
|
SubjectSubscription.js | File | 823 B | 0644 |
|
SubjectSubscription.js.map | File | 831 B | 0644 |
|
Subscriber.js | File | 7.2 KB | 0644 |
|
Subscriber.js.map | File | 5.95 KB | 0644 |
|
Subscription.js | File | 4.68 KB | 0644 |
|
Subscription.js.map | File | 3.84 KB | 0644 |
|
config.js | File | 776 B | 0644 |
|
config.js.map | File | 513 B | 0644 |
|
innerSubscribe.js | File | 1.91 KB | 0644 |
|
innerSubscribe.js.map | File | 1.94 KB | 0644 |
|
types.js | File | 33 B | 0644 |
|
types.js.map | File | 99 B | 0644 |
|