From 17f8256eff196e5479b13334e79273cef4c6aaa3 Mon Sep 17 00:00:00 2001 From: Leonardo Venturini Date: Thu, 31 Oct 2024 15:54:21 -0400 Subject: [PATCH] add setImmediate for inbound messages --- packages/ddp-server/livedata_server.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/packages/ddp-server/livedata_server.js b/packages/ddp-server/livedata_server.js index cd7a24094c..0f21be2d18 100644 --- a/packages/ddp-server/livedata_server.js +++ b/packages/ddp-server/livedata_server.js @@ -80,6 +80,8 @@ Object.assign(DummyDocumentView.prototype, { var SessionDocumentView = function () { var self = this; self.existsIn = new Set(); // set of subscriptionHandle + + // Memory Growth self.dataByKey = new Map(); // key-> [ {subscriptionHandle, value} by precedence] }; @@ -185,6 +187,7 @@ Object.assign(SessionDocumentView.prototype, { var SessionCollectionView = function (collectionName, sessionCallbacks) { var self = this; self.collectionName = collectionName; + // Memory Growth self.documents = new Map(); self.callbacks = sessionCallbacks; }; @@ -636,7 +639,7 @@ Object.assign(Session.prototype, { if (!blocked) return; // idempotent blocked = false; - processNext(); + setImmediate(processNext); }; self.server.onMessageHook.each(function (callback) {