(interval, cb)
| 779 | } |
| 780 | |
| 781 | _scheduleStalledCheck(interval, cb) { |
| 782 | if (this.checkTimer || this.paused) return; |
| 783 | this.checkTimer = setTimeout(() => { |
| 784 | // The checkTimer is unset and cleared when Queue#close is called, |
| 785 | // so we don't need to check for it here. |
| 786 | this.checkTimer = null; |
| 787 | this._safeCheckStalledJobs(interval, cb); |
| 788 | }, interval); |
| 789 | } |
| 790 | |
| 791 | _checkStalledJobs(interval, cb) { |
| 792 | const promise = this._doStalledJobCheck(); |
no test coverage detected