Merge pull request #1867 from matrix-org/luke/fix-group-request-concurrency

Prevent error responses wedging group request concurrency limit

src/stores/GroupStore.js

@@ -48,25 +48,24 @@ function checkBacklog() {
 
 // Limit the maximum number of ongoing promises returned by fn to LIMIT and
 // use a FIFO queue to handle the backlog.
-function limitConcurrency(fn) {
+async function limitConcurrency(fn) {
-    return new Promise((resolve, reject) => {
-        const item = () => {
-            ongoingRequestCount++;
-            resolve();
-        };
     if (ongoingRequestCount >= LIMIT) {
         // Enqueue this request for later execution
-            backlogQueue.push(item);
+        await new Promise((resolve, reject) => {
-        } else {
+            backlogQueue.push(resolve);
-            item();
+        });
     }
-    })
+
-    .then(fn)
+    ongoingRequestCount++;
-    .then((result) => {
+    try {
+        return await fn();
+    } catch (err) {
+        // We explicitly do not handle the error here, but let it propogate.
+        throw err;
+    } finally {
         ongoingRequestCount--;
         checkBacklog();
-        return result;
+    }
-    });
 }
 
 /**