Comparing version 3.0.11 to 3.0.12
@@ -5,2 +5,7 @@ # Change Log | ||
<a name="3.0.12"></a> | ||
## [3.0.12](https://github.com/zerkalica/lom_atom/compare/v3.0.11...v3.0.12) (2017-12-07) | ||
<a name="3.0.11"></a> | ||
@@ -7,0 +12,0 @@ ## [3.0.11](https://github.com/zerkalica/lom_atom/compare/v3.0.10...v3.0.11) (2017-12-06) |
@@ -30,5 +30,4 @@ function _defineProperties(target, props) { | ||
var catchedId = Symbol('lom_atom_catched'); | ||
var ATOM_FORCE_NONE = 0; | ||
var ATOM_FORCE_CACHE = 1; | ||
var ATOM_FORCE_ASYNC = 2; | ||
@@ -222,6 +221,3 @@ var AtomWait = | ||
this.reset(); | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} else { | ||
@@ -258,4 +254,3 @@ this._push(next); | ||
if (current instanceof Error) { | ||
if (forceCache === ATOM_FORCE_ASYNC) return proxify(current); // return proxify((current: any)) | ||
if (forceCache !== ATOM_FORCE_NONE) return proxify(current); | ||
throw current; | ||
@@ -300,2 +295,4 @@ } | ||
_proto._push = function _push(nextRaw) { | ||
if (nextRaw === undefined) return; | ||
if (!(nextRaw instanceof AtomWait)) { | ||
@@ -315,5 +312,3 @@ this._suggested = this._next; | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} | ||
@@ -332,5 +327,7 @@ }; | ||
context.current = this; | ||
var f = this.field + '$'; | ||
var next = this._next; | ||
try { | ||
newValue = this.key === undefined ? this.owner[this.field + '$'](this._next) : this.owner[this.field + '$'](this.key, this._next); | ||
newValue = this.key === undefined ? this.owner[f](next) : this.owner[f](this.key, next); | ||
} catch (error) { | ||
@@ -346,3 +343,4 @@ if (error[catchedId] === undefined) { | ||
context.current = slave; | ||
return this.status === ATOM_STATUS_ACTUAL ? this.current : newValue; | ||
if (this.status === ATOM_STATUS_DEEP_RESET) return; | ||
return newValue; | ||
}; | ||
@@ -743,2 +741,3 @@ | ||
set.call(this, next); | ||
@@ -745,0 +744,0 @@ return next; |
@@ -34,5 +34,4 @@ 'use strict'; | ||
var catchedId = Symbol('lom_atom_catched'); | ||
var ATOM_FORCE_NONE = 0; | ||
var ATOM_FORCE_CACHE = 1; | ||
var ATOM_FORCE_ASYNC = 2; | ||
@@ -226,6 +225,3 @@ var AtomWait = | ||
this.reset(); | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} else { | ||
@@ -262,4 +258,3 @@ this._push(next); | ||
if (current instanceof Error) { | ||
if (forceCache === ATOM_FORCE_ASYNC) return proxify(current); // return proxify((current: any)) | ||
if (forceCache !== ATOM_FORCE_NONE) return proxify(current); | ||
throw current; | ||
@@ -304,2 +299,4 @@ } | ||
_proto._push = function _push(nextRaw) { | ||
if (nextRaw === undefined) return; | ||
if (!(nextRaw instanceof AtomWait)) { | ||
@@ -319,5 +316,3 @@ this._suggested = this._next; | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} | ||
@@ -336,5 +331,7 @@ }; | ||
context.current = this; | ||
var f = this.field + '$'; | ||
var next = this._next; | ||
try { | ||
newValue = this.key === undefined ? this.owner[this.field + '$'](this._next) : this.owner[this.field + '$'](this.key, this._next); | ||
newValue = this.key === undefined ? this.owner[f](next) : this.owner[f](this.key, next); | ||
} catch (error) { | ||
@@ -350,3 +347,4 @@ if (error[catchedId] === undefined) { | ||
context.current = slave; | ||
return this.status === ATOM_STATUS_ACTUAL ? this.current : newValue; | ||
if (this.status === ATOM_STATUS_DEEP_RESET) return; | ||
return newValue; | ||
}; | ||
@@ -747,2 +745,3 @@ | ||
set.call(this, next); | ||
@@ -749,0 +748,0 @@ return next; |
@@ -36,5 +36,4 @@ (function (global, factory) { | ||
var catchedId = Symbol('lom_atom_catched'); | ||
var ATOM_FORCE_NONE = 0; | ||
var ATOM_FORCE_CACHE = 1; | ||
var ATOM_FORCE_ASYNC = 2; | ||
@@ -228,6 +227,3 @@ var AtomWait = | ||
this.reset(); | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} else { | ||
@@ -264,4 +260,3 @@ this._push(next); | ||
if (current instanceof Error) { | ||
if (forceCache === ATOM_FORCE_ASYNC) return proxify(current); // return proxify((current: any)) | ||
if (forceCache !== ATOM_FORCE_NONE) return proxify(current); | ||
throw current; | ||
@@ -306,2 +301,4 @@ } | ||
_proto._push = function _push(nextRaw) { | ||
if (nextRaw === undefined) return; | ||
if (!(nextRaw instanceof AtomWait)) { | ||
@@ -321,5 +318,3 @@ this._suggested = this._next; | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave); | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave); | ||
} | ||
@@ -338,5 +333,7 @@ }; | ||
context.current = this; | ||
var f = this.field + '$'; | ||
var next = this._next; | ||
try { | ||
newValue = this.key === undefined ? this.owner[this.field + '$'](this._next) : this.owner[this.field + '$'](this.key, this._next); | ||
newValue = this.key === undefined ? this.owner[f](next) : this.owner[f](this.key, next); | ||
} catch (error) { | ||
@@ -352,3 +349,4 @@ if (error[catchedId] === undefined) { | ||
context.current = slave; | ||
return this.status === ATOM_STATUS_ACTUAL ? this.current : newValue; | ||
if (this.status === ATOM_STATUS_DEEP_RESET) return; | ||
return newValue; | ||
}; | ||
@@ -749,2 +747,3 @@ | ||
set.call(this, next); | ||
@@ -751,0 +750,0 @@ return next; |
{ | ||
"name": "lom_atom", | ||
"version": "3.0.11", | ||
"version": "3.0.12", | ||
"description": "Alternative implementation of eigenmethod mol_atom state management library", | ||
@@ -5,0 +5,0 @@ "publishConfig": { |
@@ -134,5 +134,3 @@ // @flow | ||
this.reset() | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave) | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave) | ||
} else { | ||
@@ -169,4 +167,3 @@ this._push(next) | ||
if (current instanceof Error) { | ||
if (forceCache === ATOM_FORCE_ASYNC) return proxify((current: any)) | ||
// return proxify((current: any)) | ||
if (forceCache !== ATOM_FORCE_NONE) return proxify((current: any)) | ||
throw current | ||
@@ -208,3 +205,4 @@ } | ||
_push(nextRaw: V | Error): void { | ||
_push(nextRaw: V | Error | void): void { | ||
if (nextRaw === undefined) return | ||
if (!(nextRaw instanceof AtomWait)) { | ||
@@ -223,9 +221,7 @@ this._suggested = this._next | ||
this._context.newValue(this, prev, next) | ||
if (this._slaves) { | ||
this._slaves.forEach(obsoleteSlave) | ||
} | ||
if (this._slaves) this._slaves.forEach(obsoleteSlave) | ||
} | ||
} | ||
_pull(): V | Error { | ||
_pull(): V | Error | void { | ||
if (this._masters) { | ||
@@ -235,3 +231,2 @@ this._masters.forEach(disleadThis, this) | ||
let newValue: V | Error | ||
this.status = ATOM_STATUS_PULLING | ||
@@ -242,6 +237,8 @@ | ||
context.current = this | ||
const f = this.field + '$' | ||
const next = this._next | ||
try { | ||
newValue = this.key === undefined | ||
? (this.owner: any)[this.field + '$'](this._next) | ||
: (this.owner: any)[this.field + '$'](this.key, this._next) | ||
? (this.owner: any)[f](next) | ||
: (this.owner: any)[f](this.key, next) | ||
} catch (error) { | ||
@@ -257,4 +254,5 @@ if (error[catchedId] === undefined) { | ||
context.current = slave | ||
if (this.status === ATOM_STATUS_DEEP_RESET) return | ||
return this.status === ATOM_STATUS_ACTUAL ? (this.current: any) : newValue | ||
return newValue | ||
} | ||
@@ -261,0 +259,0 @@ |
// @flow | ||
import type {TypedPropertyDescriptor, IAtom} from '../interfaces' | ||
import type {TypedPropertyDescriptor, IAtom, IAtomStatus} from '../interfaces' | ||
import {ATOM_STATUS_DEEP_RESET} from '../interfaces' | ||
import {defaultContext} from '../Context' | ||
@@ -15,3 +16,3 @@ import {getId, setFunctionName} from '../utils' | ||
} | ||
(set: any).call(this, next) | ||
;(set: any).call(this, next) | ||
return next | ||
@@ -18,0 +19,0 @@ } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
341137