matrix/matrix-js-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-js-sdk.git synced 2025-11-25 05:23:13 +03:00
Code Activity

Stop using Bluebird::mapSeries

Browse Source
This commit is contained in:
Michael Telatynski
2019-11-25 14:14:10 +00:00
parent a6f7936311
commit f8d83f8273
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sync.js
View File

@@ -1150,7 +1150,7 @@ SyncApi.prototype._processSyncResponse = async function(
}); });
// Handle joins // Handle joins
await Promise.mapSeries(joinRooms, async function(joinObj) { await utils.promiseMapSeries(joinRooms, async function(joinObj) {
const room = joinObj.room; const room = joinObj.room;
const stateEvents = self._mapSyncEventsFormat(joinObj.state, room); const stateEvents = self._mapSyncEventsFormat(joinObj.state, room);
const timelineEvents = self._mapSyncEventsFormat(joinObj.timeline, room); const timelineEvents = self._mapSyncEventsFormat(joinObj.timeline, room);
@@ -1278,8 +1278,8 @@ SyncApi.prototype._processSyncResponse = async function(
} }
} }
await Promise.mapSeries(stateEvents, processRoomEvent); await utils.promiseMapSeries(stateEvents, processRoomEvent);
await Promise.mapSeries(timelineEvents, processRoomEvent); await utils.promiseMapSeries(timelineEvents, processRoomEvent);
ephemeralEvents.forEach(function(e) { ephemeralEvents.forEach(function(e) {
client.emit("event", e); client.emit("event", e);
}); });

6
src/utils.js
View File

@@ -731,3 +731,9 @@ module.exports.defer = () => {
return {resolve, reject, promise}; return {resolve, reject, promise};
}; };
module.exports.promiseMapSeries = async (promises, fn) => {
for (const o of await promises) {
await fn(await o);
}
};