Skip to content

Commit b03c996

Browse files
committed
chore: update buffered request to split each request
1 parent 391d3cd commit b03c996

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

packages/uikit-utils/src/shared/bufferedRequest.ts

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -82,12 +82,15 @@ export class BufferedRequest {
8282
}
8383
}, timeoutMills + SAFE_TIMEOUT_BUFFER);
8484

85-
nextQueue.forEach(async (func, lane) => {
86-
try {
87-
await func();
88-
} catch (e) {
89-
waitQueue.set(lane, func);
90-
}
85+
let index = 0;
86+
const nextRequestBaseTimeout = timeoutMills / nextQueue.size;
87+
nextQueue.forEach((func) => {
88+
setTimeout(() => {
89+
func();
90+
// TODO: Add retry
91+
//.catch(() => waitQueue.set(lane, func));
92+
}, nextRequestBaseTimeout * index);
93+
index++;
9194
});
9295
nextQueue.clear();
9396
},

0 commit comments

Comments
 (0)