From 4ce65d59ca91871cfd126497158200a818720bce Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Sat, 13 Apr 2024 13:30:08 +0200
Subject: Adding upstream version 0.13.1.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 .../react/event-loop/src/Tick/FutureTickQueue.php  | 60 ++++++++++++++++++++++
 1 file changed, 60 insertions(+)
 create mode 100644 vendor/react/event-loop/src/Tick/FutureTickQueue.php

(limited to 'vendor/react/event-loop/src/Tick/FutureTickQueue.php')

diff --git a/vendor/react/event-loop/src/Tick/FutureTickQueue.php b/vendor/react/event-loop/src/Tick/FutureTickQueue.php
new file mode 100644
index 0000000..efabcbc
--- /dev/null
+++ b/vendor/react/event-loop/src/Tick/FutureTickQueue.php
@@ -0,0 +1,60 @@
+<?php
+
+namespace React\EventLoop\Tick;
+
+use SplQueue;
+
+/**
+ * A tick queue implementation that can hold multiple callback functions
+ *
+ * This class should only be used internally, see LoopInterface instead.
+ *
+ * @see LoopInterface
+ * @internal
+ */
+final class FutureTickQueue
+{
+    private $queue;
+
+    public function __construct()
+    {
+        $this->queue = new SplQueue();
+    }
+
+    /**
+     * Add a callback to be invoked on a future tick of the event loop.
+     *
+     * Callbacks are guaranteed to be executed in the order they are enqueued.
+     *
+     * @param callable $listener The callback to invoke.
+     */
+    public function add($listener)
+    {
+        $this->queue->enqueue($listener);
+    }
+
+    /**
+     * Flush the callback queue.
+     */
+    public function tick()
+    {
+        // Only invoke as many callbacks as were on the queue when tick() was called.
+        $count = $this->queue->count();
+
+        while ($count--) {
+            \call_user_func(
+                $this->queue->dequeue()
+            );
+        }
+    }
+
+    /**
+     * Check if the next tick queue is empty.
+     *
+     * @return boolean
+     */
+    public function isEmpty()
+    {
+        return $this->queue->isEmpty();
+    }
+}
-- 
cgit v1.2.3