chore(temp): temp

Author: christianalfoni

packages/node_modules/non-blocking-json/src/index.ts

@@ -4,15 +4,34 @@ const IS_ARRAY_END = Symbol("IS_ARRAY_END");
 const IS_OBJECT_START = Symbol("IS_OBJECT_START");
 const IS_OBJECT_END = Symbol("IS_OBJECT_END");
 
+let QUEUE_BATCH_COUNT = 10
 let ASYNC_BATCH_COUNT = 3000;
 let TRACK_PERF = false;
 
-export const tweak = (batchCount, trackPerf) => {
+export const tweak = (queueBatchCount, batchCount, trackPerf) => {
+  QUEUE_BATCH_COUNT = queueBatchCount
   ASYNC_BATCH_COUNT = batchCount;
   TRACK_PERF = Boolean(trackPerf);
 };
 
-const next = (typeof window !== 'undefined' && window.requestAnimationFrame) || setTimeout;
+const tick = (typeof window !== 'undefined' && window.requestAnimationFrame) || setTimeout;
+const queue = (() => {
+  let pending = []
+  function pick() {
+    const picked = pending.splice(0, QUEUE_BATCH_COUNT)
+    picked.forEach(cb => cb())
+    if (pending.length) {
+      tick(pick)
+    }
+  }
+  return (cb) => {
+    pending.push(cb)
+
+    if (pending.length === 1) {
+      pick()
+    }    
+  }
+})()
 
 /*
   This function takes a value which results in a Map of
@@ -65,7 +84,7 @@ function isRef(ref) {
 */
 export function stringify(value, replacer?) {
   return new Promise<string>(resolve => {
-    next(async () => {
+    queue(async () => {
       const paths = getPaths(value, new Map(), replacer ? replacer.bind(global || window) : replacer);
       const structs = [];
       let prevKey = [];
@@ -85,7 +104,7 @@ export function stringify(value, replacer?) {
             console.log("PERF - ", end - start)
             start = end
           }
-          await new Promise(resolve => next(resolve));
+          await new Promise(resolve => queue(resolve));
         }
 
         x++;
@@ -168,7 +187,7 @@ export async function parse(value) {
         console.log("PERF - ", end - start)
         start = end
       }
-      await new Promise(resolve => next(resolve));
+      await new Promise(resolve => queue(resolve));
     }
 
     if (value[charIndex] === '"' && value[charIndex - 1] !== '\\') {
@@ -218,7 +237,7 @@ export async function parse(value) {
     const keys = Object.keys(parsedValue);
 
     if (i && i % ASYNC_BATCH_COUNT === 0) {
-      await new Promise(resolve => next(resolve));
+      await new Promise(resolve => queue(resolve));
     }
 
     return Promise.all(

packages/node_modules/overmind/src/index.ts

@@ -662,6 +662,7 @@ export class Overmind<ThisConfig extends IConfiguration>
 
           let pendingFlush
           mutationTree.onMutation((mutation) => {
+            console.log("WTF?", mutation)
             if (pendingFlush) {
               clearTimeout(pendingFlush)
             }