@aurox/distributed-observables
Advanced tools
Comparing version 0.1.2 to 0.1.3
@@ -11,3 +11,3 @@ import { TypedEmitter } from 'tiny-typed-emitter'; | ||
'conflict-reported': (message: string, actualValue: T, actualRevision: number) => void; | ||
'error': (message: string) => void; | ||
'error-reported': (message: string) => void; | ||
'detached': () => void; | ||
@@ -14,0 +14,0 @@ } |
@@ -46,3 +46,3 @@ "use strict"; | ||
this._persistRetryTimer = setTimeout(this.persist, this._retryTimeout); | ||
this.emit('error', result.message); | ||
this.emit('error-reported', result.message); | ||
return; | ||
@@ -71,3 +71,3 @@ } | ||
this._persistRetryTimer = setTimeout(this.persist, this._retryTimeout); | ||
this.emit('error', (_a = error === null || error === void 0 ? void 0 : error.message) !== null && _a !== void 0 ? _a : 'Unknown Error'); | ||
this.emit('error-reported', (_a = error === null || error === void 0 ? void 0 : error.message) !== null && _a !== void 0 ? _a : 'Unknown Error'); | ||
} | ||
@@ -120,3 +120,3 @@ finally { | ||
this._invalidReason = result.message; | ||
this.emit('error', result.message); | ||
this.emit('error-reported', result.message); | ||
return null; | ||
@@ -133,3 +133,3 @@ } | ||
this._invalidReason = (_a = error === null || error === void 0 ? void 0 : error.message) !== null && _a !== void 0 ? _a : 'Unknown Reason'; | ||
this.emit('error', (_b = error === null || error === void 0 ? void 0 : error.message) !== null && _b !== void 0 ? _b : 'Unknown Error'); | ||
this.emit('error-reported', (_b = error === null || error === void 0 ? void 0 : error.message) !== null && _b !== void 0 ? _b : 'Unknown Error'); | ||
throw error; | ||
@@ -136,0 +136,0 @@ } |
{ | ||
"name": "@aurox/distributed-observables", | ||
"version": "0.1.2", | ||
"version": "0.1.3", | ||
"description": "A set of isomorphic helpers to enable distributed object sharing using the observer pattern", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
@@ -16,3 +16,3 @@ import { Patch, produceWithPatches, applyPatches } from 'immer'; | ||
'conflict-reported': (message: string, actualValue: T, actualRevision: number) => void; | ||
'error': (message: string) => void; | ||
'error-reported': (message: string) => void; | ||
'detached': () => void; | ||
@@ -109,3 +109,3 @@ } | ||
this.emit('error', result.message); | ||
this.emit('error-reported', result.message); | ||
@@ -127,3 +127,3 @@ return null; | ||
this.emit('error', error?.message ?? 'Unknown Error'); | ||
this.emit('error-reported', error?.message ?? 'Unknown Error'); | ||
@@ -226,3 +226,3 @@ throw error; | ||
this.emit('error', result.message); | ||
this.emit('error-reported', result.message); | ||
@@ -266,3 +266,3 @@ return; | ||
this.emit('error', error?.message ?? 'Unknown Error'); | ||
this.emit('error-reported', error?.message ?? 'Unknown Error'); | ||
} finally { | ||
@@ -269,0 +269,0 @@ this._applyPatchPromise = null; |
Sorry, the diff of this file is not supported yet
114313