Skip to content

Commit 9d05ae5

Browse files
committed
no need to wrap it
1 parent f1aedb6 commit 9d05ae5

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

packages/core/src/utils/promisebuffer.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -56,15 +56,15 @@ export function makePromiseBuffer<T>(limit: number = 100): PromiseBuffer<T> {
5656
return task;
5757
}
5858

59-
function drainNextSyncPromise(): PromiseLike<boolean> {
60-
const item = buffer.values().next().value;
59+
function _drainNextSyncPromise(): PromiseLike<boolean> {
60+
const item = buffer.values().next().value as PromiseLike<T>;
6161

6262
if (!item) {
6363
return resolvedSyncPromise(true);
6464
}
6565

66-
return resolvedSyncPromise(item).then(() => {
67-
return drainNextSyncPromise();
66+
return item.then(() => {
67+
return _drainNextSyncPromise();
6868
});
6969
}
7070

@@ -82,7 +82,7 @@ export function makePromiseBuffer<T>(limit: number = 100): PromiseBuffer<T> {
8282
return resolvedSyncPromise(true);
8383
}
8484

85-
const drainPromise = drainNextSyncPromise();
85+
const drainPromise = _drainNextSyncPromise();
8686

8787
if (!timeout) {
8888
return drainPromise;

0 commit comments

Comments
 (0)