File tree Expand file tree Collapse file tree 1 file changed +1
-12
lines changed Expand file tree Collapse file tree 1 file changed +1
-12
lines changed Original file line number Diff line number Diff line change @@ -24,10 +24,8 @@ function allPromises<U = unknown>(collection: Array<U | PromiseLike<U>>): Promis
24
24
25
25
export interface PromiseBuffer < T > {
26
26
_buffer : Array < PromiseLike < T > > ;
27
- isReady ( ) : boolean ;
28
27
add ( taskProducer : ( ) => PromiseLike < T > ) : PromiseLike < T > ;
29
28
remove ( task : PromiseLike < T > ) : PromiseLike < T > ;
30
- length ( ) : number ;
31
29
drain ( timeout ?: number ) : PromiseLike < boolean > ;
32
30
}
33
31
@@ -38,15 +36,8 @@ export interface PromiseBuffer<T> {
38
36
export function makePromiseBuffer < T > ( limit ?: number ) : PromiseBuffer < T > {
39
37
const buffer : Array < PromiseLike < T > > = [ ] ;
40
38
41
- /**
42
- * This function returns the number of unresolved promises in the queue.
43
- */
44
- function length ( ) : number {
45
- return buffer . length ;
46
- }
47
-
48
39
function isReady ( ) : boolean {
49
- return limit === undefined || length ( ) < limit ;
40
+ return limit === undefined || buffer . length < limit ;
50
41
}
51
42
52
43
/**
@@ -120,8 +111,6 @@ export function makePromiseBuffer<T>(limit?: number): PromiseBuffer<T> {
120
111
121
112
const promiseBuffer : PromiseBuffer < T > = {
122
113
_buffer : buffer ,
123
- length,
124
- isReady,
125
114
add,
126
115
remove,
127
116
drain,
You can’t perform that action at this time.
0 commit comments