From f8d83f8273aa7d66f5df8994f46b119d30db0771 Mon Sep 17 00:00:00 2001 From: Michael Telatynski <7t3chguy@gmail.com> Date: Mon, 25 Nov 2019 14:14:10 +0000 Subject: [PATCH] Stop using Bluebird::mapSeries --- src/sync.js | 6 +++--- src/utils.js | 6 ++++++ 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/sync.js b/src/sync.js index 590cc16b4..a5e1ab12c 100644 --- a/src/sync.js +++ b/src/sync.js @@ -1150,7 +1150,7 @@ SyncApi.prototype._processSyncResponse = async function( }); // Handle joins - await Promise.mapSeries(joinRooms, async function(joinObj) { + await utils.promiseMapSeries(joinRooms, async function(joinObj) { const room = joinObj.room; const stateEvents = self._mapSyncEventsFormat(joinObj.state, room); const timelineEvents = self._mapSyncEventsFormat(joinObj.timeline, room); @@ -1278,8 +1278,8 @@ SyncApi.prototype._processSyncResponse = async function( } } - await Promise.mapSeries(stateEvents, processRoomEvent); - await Promise.mapSeries(timelineEvents, processRoomEvent); + await utils.promiseMapSeries(stateEvents, processRoomEvent); + await utils.promiseMapSeries(timelineEvents, processRoomEvent); ephemeralEvents.forEach(function(e) { client.emit("event", e); }); diff --git a/src/utils.js b/src/utils.js index 49863ecd8..c24df57aa 100644 --- a/src/utils.js +++ b/src/utils.js @@ -731,3 +731,9 @@ module.exports.defer = () => { return {resolve, reject, promise}; }; + +module.exports.promiseMapSeries = async (promises, fn) => { + for (const o of await promises) { + await fn(await o); + } +};