emit events on queue instance
This commit is contained in:
@@ -66,6 +66,11 @@ export default class Job extends events.EventEmitter {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
emit(name, ...args) {
|
||||||
|
super.emit(name, ...args);
|
||||||
|
this.queue.emit(name, ...args);
|
||||||
|
}
|
||||||
|
|
||||||
get() {
|
get() {
|
||||||
return this.ready
|
return this.ready
|
||||||
.then(() => {
|
.then(() => {
|
||||||
|
|||||||
Reference in New Issue
Block a user