Skip to content

Commit d96316e

Browse files
committed
refactor: simplefy processQueue.ts
Signed-off-by: Raccoon <[email protected]>
1 parent e5797ae commit d96316e

File tree

1 file changed

+1
-19
lines changed

1 file changed

+1
-19
lines changed

lib/realtime/processQueue.ts

+1-19
Original file line numberDiff line numberDiff 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-
4023
export 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-

0 commit comments

Comments
 (0)