New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

nemo-observable-util

Package Overview
Dependencies
Maintainers
3
Versions
37
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

nemo-observable-util - npm Package Compare versions

Comparing version 5.3.1 to 5.3.2

12

dist/cjs.es5.js

@@ -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",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc