Fix taskQueue premature promise resolution

This commit is contained in:
Zaid Abdulla committed 2018-12-26 00:22:07 -08:00
1 parent 12cdc8a6f1
commit d222e488c2
1 file changed
+3 -1
+3 -1
View File
@@ -46,7 +46,8 @@ function commit(tasks, callback) {
return new Promise(resolve => {
let counter = 1;
for (let [deviceId, tasks2] of Object.entries(devices))
for (let [deviceId, tasks2] of Object.entries(devices)) {
++counter;
store
.postTasks(deviceId, tasks)
.then(connectionRequestStatus => {
@@ -61,6 +62,7 @@ function commit(tasks, callback) {
callback(deviceId, err, null, tasks2);
if (--counter === 0) resolve();
});
}
if (--counter === 0) resolve();
});