@randajan/jet-core
Advanced tools
Comparing version 3.2.21 to 3.3.0
@@ -540,2 +540,3 @@ var __defProp = Object.defineProperty; | ||
var vault = (name) => { | ||
console.warn(`jet.vault("${name}") being deprecated use native WeakMap instead`); | ||
const vault2 = {}; | ||
@@ -661,2 +662,25 @@ let keyNext = 1; | ||
// src/jet/buffer.js | ||
var buffer = (processQueue, bufferMs = 100, maxQueueSize = 100) => { | ||
if (!jet.isRunnable(processQueue)) { | ||
throw new Error("jet.buffer(...) require function as a first argument"); | ||
} | ||
bufferMs = Math.max(0, Number.jet.to(bufferMs)); | ||
maxQueueSize = Math.max(0, Number.jet.to(maxQueueSize)); | ||
let int, queue = []; | ||
const execute = (_) => { | ||
const q = queue; | ||
queue = []; | ||
processQueue(q); | ||
}; | ||
return (...args) => { | ||
clearTimeout(int); | ||
if (maxQueueSize && queue.length >= maxQueueSize) { | ||
return execute(); | ||
} | ||
queue.push(args); | ||
int = setTimeout(execute, bufferMs); | ||
}; | ||
}; | ||
// src/jet/index.js | ||
@@ -714,2 +738,3 @@ Plex_default.extend(defs_default, { | ||
prop: props_exports, | ||
buffer, | ||
...pile_exports, | ||
@@ -716,0 +741,0 @@ define: new Plex_default(define_default, { to: defineTo, extend: defineExtend }) |
{ | ||
"name": "@randajan/jet-core", | ||
"version": "3.2.21", | ||
"version": "3.3.0", | ||
"description": "Ecosystem of types and related usefull tools.", | ||
@@ -5,0 +5,0 @@ "repository": "randajan/jet-core", |
Sorry, the diff of this file is not supported yet
151650
1482