@@ -87,7 +87,7 @@ export async function runJob(name: string, options: JobOptions = {}): Promise<vo
87
87
}
88
88
}
89
89
90
- export class Dispatch implements Dispatchable {
90
+ export class Queue implements Dispatchable {
91
91
protected options : JobOptions = { }
92
92
93
93
constructor (
@@ -196,31 +196,31 @@ export class Dispatch implements Dispatchable {
196
196
}
197
197
198
198
export class JobFactory {
199
- static make ( name : string , payload ?: any ) : Dispatch {
200
- return new Dispatch ( name , payload )
199
+ static make ( name : string , payload ?: any ) : Queue {
200
+ return new Queue ( name , payload )
201
201
}
202
202
203
- static dispatch ( name : string , payload ?: any ) : Dispatch {
204
- const job = new Dispatch ( name , payload )
203
+ static dispatch ( name : string , payload ?: any ) : Queue {
204
+ const job = new Queue ( name , payload )
205
205
job . dispatch ( )
206
206
return job
207
207
}
208
208
209
209
static async dispatchNow ( name : string , payload ?: any ) : Promise < void > {
210
- await new Dispatch ( name , payload ) . dispatchNow ( )
210
+ await new Queue ( name , payload ) . dispatchNow ( )
211
211
}
212
212
213
- static later ( delay : number , name : string , payload ?: any ) : Dispatch {
214
- return new Dispatch ( name , payload ) . delay ( delay )
213
+ static later ( delay : number , name : string , payload ?: any ) : Queue {
214
+ return new Queue ( name , payload ) . delay ( delay )
215
215
}
216
216
217
- static chain ( jobs : Dispatch [ ] ) : Dispatch {
217
+ static chain ( jobs : Queue [ ] ) : Queue {
218
218
const firstJob = jobs [ 0 ]
219
219
return firstJob . chain ( jobs . slice ( 1 ) )
220
220
}
221
221
}
222
222
223
- export function job ( name : string , payload ?: any ) : Dispatch {
223
+ export function job ( name : string , payload ?: any ) : Queue {
224
224
return JobFactory . make ( name , payload )
225
225
}
226
226
0 commit comments