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

Method preventStalling

lib/queue.js:545–553  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

543 completed = false;
544
545 const preventStalling = () => {
546 psTimeout = null;
547 if (this._isClosed) return;
548 finally_(this._preventStall(job.id), () => {
549 if (completed || this._isClosed) return;
550 const interval = this.settings.stallInterval / 2;
551 psTimeout = setTimeout(preventStalling, interval);
552 }).catch(this._emitErrorAfterTick);
553 };
554 preventStalling();
555
556 const handleOutcome = (err, data) => {

Callers

nothing calls this directly

Calls 1

_preventStallMethod · 0.95

Tested by

no test coverage detected