File tree Expand file tree Collapse file tree 1 file changed +1
-19
lines changed Expand file tree Collapse file tree 1 file changed +1
-19
lines changed Original file line number Diff line number Diff line change @@ -20,23 +20,6 @@ interface Task {
2020 processingFunc : TaskFunc
2121}
2222
23-
24- export interface ProcessQueueOptions {
25- maximumLength ?: number
26- triggerTimeInterval ?: number
27- proactiveMode ?: boolean
28- continuousMode ?: boolean
29- }
30-
31- const defaultOptions : ProcessQueueOptions = {
32- maximumLength : 500 ,
33- triggerTimeInterval : 5000 ,
34- // execute on push
35- proactiveMode : true ,
36- // execute next work on finish
37- continuousMode : true
38- }
39-
4023export class ProcessQueue extends EventEmitter implements JobWorker {
4124 private readonly max : number ;
4225 private readonly triggerTime : number ;
@@ -52,7 +35,7 @@ export class ProcessQueue extends EventEmitter implements JobWorker {
5235 proactiveMode = true ,
5336 // execute next work on finish
5437 continuousMode = true
55- } : ProcessQueueOptions = { } ) {
38+ } = { } ) {
5639 super ( )
5740 this . max = maximumLength
5841 this . triggerTime = triggerTimeInterval
@@ -140,4 +123,3 @@ export class ProcessQueue extends EventEmitter implements JobWorker {
140123 }
141124 }
142125}
143-
You can’t perform that action at this time.
0 commit comments