SafeObserver

SafeObserver.ts

			class SafeObserver {
				constructor(private _next: (value: any) => void = () => {},
							public error: (errorValue: any) => void = (e: any) => { throw e; },
							private _complete: (completeValue?: any) => void = () => {}) {}
				
				public next(value: any) {
					try {
						this._next(value);
					}
					catch (e) {
						this.error(e);
					}
				}

				public complete(value: any) {
					try {
						this._complete(value);
					}
					catch (e) {
						this.error(e);
					}
				}
			}