Edit File by line

<?php

[0] Fix | Delete

[1] Fix | Delete

declare (strict_types=1);

[2] Fix | Delete

namespace YoastSEO_Vendor\GuzzleHttp\Promise;

[3] Fix | Delete

[4] Fix | Delete

/**

[5] Fix | Delete

* A task queue that executes tasks in a FIFO order.

[6] Fix | Delete

[7] Fix | Delete

* This task queue class is used to settle promises asynchronously and

[8] Fix | Delete

* maintains a constant stack size. You can use the task queue asynchronously

[9] Fix | Delete

* by calling the `run()` function of the global task queue in an event loop.

[10] Fix | Delete

[11] Fix | Delete

* GuzzleHttp\Promise\Utils::queue()->run();

[12] Fix | Delete

[13] Fix | Delete

* @final

[14] Fix | Delete

[15] Fix | Delete

class TaskQueue implements \YoastSEO_Vendor\GuzzleHttp\Promise\TaskQueueInterface

[16] Fix | Delete

{

[17] Fix | Delete

private $enableShutdown = \true;

[18] Fix | Delete

private $queue = [];

[19] Fix | Delete

public function __construct(bool $withShutdown = \true)

[20] Fix | Delete

{

[21] Fix | Delete

if ($withShutdown) {

[22] Fix | Delete

\register_shutdown_function(function () : void {

[23] Fix | Delete

if ($this->enableShutdown) {

[24] Fix | Delete

// Only run the tasks if an E_ERROR didn't occur.

[25] Fix | Delete

$err = \error_get_last();

[26] Fix | Delete

if (!$err || $err['type'] ^ \E_ERROR) {

[27] Fix | Delete

$this->run();

[28] Fix | Delete

}

[29] Fix | Delete

}

[30] Fix | Delete

});

[31] Fix | Delete

}

[32] Fix | Delete

}

[33] Fix | Delete

public function isEmpty() : bool

[34] Fix | Delete

{

[35] Fix | Delete

return !$this->queue;

[36] Fix | Delete

}

[37] Fix | Delete

public function add(callable $task) : void

[38] Fix | Delete

{

[39] Fix | Delete

$this->queue[] = $task;

[40] Fix | Delete

}

[41] Fix | Delete

public function run() : void

[42] Fix | Delete

{

[43] Fix | Delete

while ($task = \array_shift($this->queue)) {

[44] Fix | Delete

/** @var callable $task */

[45] Fix | Delete

$task();

[46] Fix | Delete

}

[47] Fix | Delete

}

[48] Fix | Delete

/**

[49] Fix | Delete

* The task queue will be run and exhausted by default when the process

[50] Fix | Delete

* exits IFF the exit is not the result of a PHP E_ERROR error.

[51] Fix | Delete

[52] Fix | Delete

* You can disable running the automatic shutdown of the queue by calling

[53] Fix | Delete

* this function. If you disable the task queue shutdown process, then you

[54] Fix | Delete

* MUST either run the task queue (as a result of running your event loop

[55] Fix | Delete

* or manually using the run() method) or wait on each outstanding promise.

[56] Fix | Delete

[57] Fix | Delete

* Note: This shutdown will occur before any destructors are triggered.

[58] Fix | Delete

[59] Fix | Delete

public function disableShutdown() : void

[60] Fix | Delete

{

[61] Fix | Delete

$this->enableShutdown = \false;

[62] Fix | Delete

}

[63] Fix | Delete

}

[64] Fix | Delete

[65] Fix | Delete