Skip to content

Commit

Permalink
fix(Notification): replace const enum (ReactiveX#4556)
Browse files Browse the repository at this point in the history
* fix(Notification): replace const enum

Closes ReactiveX#4538

* chore: use literal union and keep enum

The enum is kept, but it is no longer a const enum. It cannot be exported as a const enum without effecting an error if isolated modules are used.
  • Loading branch information
cartant authored and BioPhoton committed May 15, 2019
1 parent 14033db commit 7a05819
Showing 1 changed file with 21 additions and 16 deletions.
37 changes: 21 additions & 16 deletions src/internal/Notification.ts
Expand Up @@ -3,8 +3,13 @@ import { Observable } from './Observable';
import { empty } from './observable/empty';
import { of } from './observable/of';
import { throwError } from './observable/throwError';
import { deprecate } from 'util';

export const enum NotificationKind {
// TODO: When this enum is removed, replace it with a type alias. See #4556.
/**
* @deprecated NotificationKind is deprecated as const enums are not compatible with isolated modules. Use a string literal instead.
*/
export enum NotificationKind {
NEXT = 'N',
ERROR = 'E',
COMPLETE = 'C',
Expand All @@ -27,8 +32,8 @@ export const enum NotificationKind {
export class Notification<T> {
hasValue: boolean;

constructor(public kind: NotificationKind, public value?: T, public error?: any) {
this.hasValue = kind === NotificationKind.NEXT;
constructor(public kind: 'N' | 'E' | 'C', public value?: T, public error?: any) {
this.hasValue = kind === 'N';
}

/**
Expand All @@ -38,11 +43,11 @@ export class Notification<T> {
*/
observe(observer: PartialObserver<T>): any {
switch (this.kind) {
case NotificationKind.NEXT:
case 'N':
return observer.next && observer.next(this.value);
case NotificationKind.ERROR:
case 'E':
return observer.error && observer.error(this.error);
case NotificationKind.COMPLETE:
case 'C':
return observer.complete && observer.complete();
}
}
Expand All @@ -58,11 +63,11 @@ export class Notification<T> {
do(next: (value: T) => void, error?: (err: any) => void, complete?: () => void): any {
const kind = this.kind;
switch (kind) {
case NotificationKind.NEXT:
case 'N':
return next && next(this.value);
case NotificationKind.ERROR:
case 'E':
return error && error(this.error);
case NotificationKind.COMPLETE:
case 'C':
return complete && complete();
}
}
Expand Down Expand Up @@ -92,18 +97,18 @@ export class Notification<T> {
toObservable(): Observable<T> {
const kind = this.kind;
switch (kind) {
case NotificationKind.NEXT:
case 'N':
return of(this.value);
case NotificationKind.ERROR:
case 'E':
return throwError(this.error);
case NotificationKind.COMPLETE:
case 'C':
return empty();
}
throw new Error('unexpected notification kind value');
}

private static completeNotification: Notification<any> = new Notification(NotificationKind.COMPLETE);
private static undefinedValueNotification: Notification<any> = new Notification(NotificationKind.NEXT, undefined);
private static completeNotification: Notification<any> = new Notification('C');
private static undefinedValueNotification: Notification<any> = new Notification('N', undefined);

/**
* A shortcut to create a Notification instance of the type `next` from a
Expand All @@ -115,7 +120,7 @@ export class Notification<T> {
*/
static createNext<T>(value: T): Notification<T> {
if (typeof value !== 'undefined') {
return new Notification(NotificationKind.NEXT, value);
return new Notification('N', value);
}
return Notification.undefinedValueNotification;
}
Expand All @@ -129,7 +134,7 @@ export class Notification<T> {
* @nocollapse
*/
static createError<T>(err?: any): Notification<T> {
return new Notification(NotificationKind.ERROR, undefined, err);
return new Notification('E', undefined, err);
}

/**
Expand Down

0 comments on commit 7a05819

Please sign in to comment.