nemo-observable-util
Advanced tools
Comparing version 5.3.1 to 5.3.2
@@ -102,3 +102,3 @@ 'use strict'; | ||
var suffix = ref[1]; | ||
this.onFlush && this.onFlush(suffix); | ||
this.onFlush && this.onFlush(suffix, target); | ||
} | ||
@@ -208,3 +208,3 @@ }; | ||
this.flush = function (actionName) { | ||
this.flush = function (actionName, uuid) { | ||
// copy incase being modified during exec reaction | ||
@@ -215,3 +215,3 @@ var todoCopy = this$1.runners; | ||
for (var [reaction, operation] of todoCopy.entries()) { | ||
queueReaction(reaction, operation, actionName); | ||
queueReaction(reaction, operation, actionName, uuid); | ||
} | ||
@@ -468,11 +468,11 @@ }; | ||
function queueReaction(reaction, operation, actionName) { | ||
function queueReaction(reaction, operation, actionName, uuid) { | ||
debugOperation(reaction, operation); | ||
// queue the reaction for later execution or run it immediately | ||
if (typeof reaction.scheduler === 'function') { | ||
reaction.scheduler(reaction, actionName); | ||
reaction.scheduler(reaction, actionName, uuid); | ||
} else if (typeof reaction.scheduler === 'object') { | ||
reaction.scheduler.add(reaction); | ||
} else { | ||
reaction(actionName); | ||
reaction(actionName, uuid); | ||
} | ||
@@ -479,0 +479,0 @@ } |
@@ -92,3 +92,3 @@ 'use strict'; | ||
const [, suffix] = typeof lastStack === 'string' ? lastStack.split('@@') : []; | ||
this.onFlush && this.onFlush(suffix); | ||
this.onFlush && this.onFlush(suffix, target); | ||
} | ||
@@ -184,3 +184,3 @@ } | ||
constructor() { | ||
this.flush = actionName => { | ||
this.flush = (actionName, uuid) => { | ||
// copy incase being modified during exec reaction | ||
@@ -191,3 +191,3 @@ const todoCopy = this.runners; | ||
for (const [reaction, operation] of todoCopy.entries()) { | ||
queueReaction(reaction, operation, actionName); | ||
queueReaction(reaction, operation, actionName, uuid); | ||
} | ||
@@ -421,11 +421,11 @@ }; | ||
function queueReaction(reaction, operation, actionName) { | ||
function queueReaction(reaction, operation, actionName, uuid) { | ||
debugOperation(reaction, operation); | ||
// queue the reaction for later execution or run it immediately | ||
if (typeof reaction.scheduler === 'function') { | ||
reaction.scheduler(reaction, actionName); | ||
reaction.scheduler(reaction, actionName, uuid); | ||
} else if (typeof reaction.scheduler === 'object') { | ||
reaction.scheduler.add(reaction); | ||
} else { | ||
reaction(actionName); | ||
reaction(actionName, uuid); | ||
} | ||
@@ -432,0 +432,0 @@ } |
@@ -98,3 +98,3 @@ var connectionStore = new WeakMap(); | ||
var suffix = ref[1]; | ||
this.onFlush && this.onFlush(suffix); | ||
this.onFlush && this.onFlush(suffix, target); | ||
} | ||
@@ -204,3 +204,3 @@ }; | ||
this.flush = function (actionName) { | ||
this.flush = function (actionName, uuid) { | ||
// copy incase being modified during exec reaction | ||
@@ -211,3 +211,3 @@ var todoCopy = this$1.runners; | ||
for (var [reaction, operation] of todoCopy.entries()) { | ||
queueReaction(reaction, operation, actionName); | ||
queueReaction(reaction, operation, actionName, uuid); | ||
} | ||
@@ -464,11 +464,11 @@ }; | ||
function queueReaction(reaction, operation, actionName) { | ||
function queueReaction(reaction, operation, actionName, uuid) { | ||
debugOperation(reaction, operation); | ||
// queue the reaction for later execution or run it immediately | ||
if (typeof reaction.scheduler === 'function') { | ||
reaction.scheduler(reaction, actionName); | ||
reaction.scheduler(reaction, actionName, uuid); | ||
} else if (typeof reaction.scheduler === 'object') { | ||
reaction.scheduler.add(reaction); | ||
} else { | ||
reaction(actionName); | ||
reaction(actionName, uuid); | ||
} | ||
@@ -475,0 +475,0 @@ } |
@@ -88,3 +88,3 @@ const connectionStore = new WeakMap(); | ||
const [, suffix] = typeof lastStack === 'string' ? lastStack.split('@@') : []; | ||
this.onFlush && this.onFlush(suffix); | ||
this.onFlush && this.onFlush(suffix, target); | ||
} | ||
@@ -180,3 +180,3 @@ } | ||
constructor() { | ||
this.flush = actionName => { | ||
this.flush = (actionName, uuid) => { | ||
// copy incase being modified during exec reaction | ||
@@ -187,3 +187,3 @@ const todoCopy = this.runners; | ||
for (const [reaction, operation] of todoCopy.entries()) { | ||
queueReaction(reaction, operation, actionName); | ||
queueReaction(reaction, operation, actionName, uuid); | ||
} | ||
@@ -417,11 +417,11 @@ }; | ||
function queueReaction(reaction, operation, actionName) { | ||
function queueReaction(reaction, operation, actionName, uuid) { | ||
debugOperation(reaction, operation); | ||
// queue the reaction for later execution or run it immediately | ||
if (typeof reaction.scheduler === 'function') { | ||
reaction.scheduler(reaction, actionName); | ||
reaction.scheduler(reaction, actionName, uuid); | ||
} else if (typeof reaction.scheduler === 'object') { | ||
reaction.scheduler.add(reaction); | ||
} else { | ||
reaction(actionName); | ||
reaction(actionName, uuid); | ||
} | ||
@@ -428,0 +428,0 @@ } |
{ | ||
"name": "nemo-observable-util", | ||
"version": "5.3.1", | ||
"version": "5.3.2", | ||
"description": "Simple transparent reactivity with 100% language coverage. Made with ES6 Proxies.", | ||
@@ -5,0 +5,0 @@ "main": "dist/cjs.es5.js", |
129150