diff options
author | marvin-borner@live.com | 2018-04-16 21:09:05 +0200 |
---|---|---|
committer | marvin-borner@live.com | 2018-04-16 21:09:05 +0200 |
commit | cf14306c2b3f82a81f8d56669a71633b4d4b5fce (patch) | |
tree | 86700651aa180026e89a66064b0364b1e4346f3f /assets/php/vendor/react/promise/src/CancellationQueue.php | |
parent | 619b01b3615458c4ed78bfaeabb6b1a47cc8ad8b (diff) |
Main merge to user management system - files are now at /main/public/
Diffstat (limited to 'assets/php/vendor/react/promise/src/CancellationQueue.php')
-rwxr-xr-x | assets/php/vendor/react/promise/src/CancellationQueue.php | 55 |
1 files changed, 0 insertions, 55 deletions
diff --git a/assets/php/vendor/react/promise/src/CancellationQueue.php b/assets/php/vendor/react/promise/src/CancellationQueue.php deleted file mode 100755 index a366994..0000000 --- a/assets/php/vendor/react/promise/src/CancellationQueue.php +++ /dev/null @@ -1,55 +0,0 @@ -<?php - -namespace React\Promise; - -class CancellationQueue -{ - private $started = false; - private $queue = []; - - public function __invoke() - { - if ($this->started) { - return; - } - - $this->started = true; - $this->drain(); - } - - public function enqueue($cancellable) - { - if (!method_exists($cancellable, 'then') || !method_exists($cancellable, 'cancel')) { - return; - } - - $length = array_push($this->queue, $cancellable); - - if ($this->started && 1 === $length) { - $this->drain(); - } - } - - private function drain() - { - for ($i = key($this->queue); isset($this->queue[$i]); $i++) { - $cancellable = $this->queue[$i]; - - $exception = null; - - try { - $cancellable->cancel(); - } catch (\Throwable $exception) { - } catch (\Exception $exception) { - } - - unset($this->queue[$i]); - - if ($exception) { - throw $exception; - } - } - - $this->queue = []; - } -} |