MCPcopy Index your code
hub / github.com/bee-queue/bee-queue / _scheduleStalledCheck

Method _scheduleStalledCheck

lib/queue.js:781–789  ·  view source on GitHub ↗
(interval, cb)

Source from the content-addressed store, hash-verified

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();

Callers 1

_checkStalledJobsMethod · 0.95

Calls 1

_safeCheckStalledJobsMethod · 0.95

Tested by

no test coverage detected