Scope validation and driver retrieval

Author: AndrewCarterUK

src/EventLoop.php

@@ -32,13 +32,27 @@ public static function execute(callable $callback, EventLoopDriver $driver)
         }
     }
 
+    /**
+     * Retrieve the event loop driver that is in scope.
+     * 
+     * @return EventLoopDriver
+     */
+    public static function get()
+    {
+        self::inScope();
+
+        return self::$driver;
+    }
+
     /**
      * Stop the event loop.
      * 
      * @return void
      */
     public static function stop()
     {
+        self::inScope();
+
         self::$driver->stop();
     }
 
@@ -51,6 +65,8 @@ public static function stop()
      */
     public static function defer(callable $callback)
     {
+        self::inScope();
+
         return self::$driver->defer($callback);
     }
 
@@ -64,6 +80,8 @@ public static function defer(callable $callback)
      */
     public static function delay(callable $callback, float $time)
     {
+        self::inScope();
+
         return self::$driver->delay($callback, $time);
     }
 
@@ -77,6 +95,8 @@ public static function delay(callable $callback, float $time)
      */
     public static function repeat(callable $callback, float $interval)
     {
+        self::inScope();
+
         return self::$driver->repeat($callback, $interval);
     }
 
@@ -90,6 +110,8 @@ public static function repeat(callable $callback, float $interval)
      */
     public static function onReadable($stream, callable $callback)
     {
+        self::inScope();
+
         return self::$driver->onReadable($stream, $callback);
     }
 
@@ -103,6 +125,8 @@ public static function onReadable($stream, callable $callback)
      */
     public function onWritable($stream, callable $callback)
     {
+        self::inScope();
+
         return self::$driver->onWritable($stream, $callback);
     }
 
@@ -116,6 +140,8 @@ public function onWritable($stream, callable $callback)
      */
     public function onSignal(int $signo, callable $callback)
     {
+        self::inScope();
+
         return self::$driver->onSignal($signo, $callback);
     }
 
@@ -128,6 +154,8 @@ public function onSignal(int $signo, callable $callback)
      */
     public function onError(callable $callback)
     {
+        self::inScope();
+
         return self::$driver->onError($callback);
     }
 
@@ -140,6 +168,8 @@ public function onError(callable $callback)
      */
     public function enable(string $eventIdentifier)
     {
+        self::inScope();
+
         self::$driver->enable($eventIdentifier);
     }
 
@@ -152,6 +182,8 @@ public function enable(string $eventIdentifier)
      */
     public function disable(string $eventIdentifier)
     {
+        self::inScope();
+
         self::$driver->disable($eventIdentifier);
     }
 
@@ -164,6 +196,8 @@ public function disable(string $eventIdentifier)
      */
     public function cancel(string $eventIdentifier)
     {
+        self::inScope();
+
         self::$driver->cancel($eventIdentifier);
     }
 
@@ -178,6 +212,8 @@ public function cancel(string $eventIdentifier)
      */
     public function reference(string $eventIdentifier)
     {
+        self::inScope();
+
         self::$driver->reference($eventIdentifier);
     }
 
@@ -193,9 +229,23 @@ public function reference(string $eventIdentifier)
      */
     public function unreference(string $eventIdentifier)
     {
+        self::inScope();
+
         self::$driver->unreference($eventIdentifier);
     }
 
+    /**
+     * Validate that the event loop is currently within the scope of a driver.
+     * 
+     * @return void
+     */
+    private static function inScope()
+    {
+        if (null === self::$driver) {
+            throw new \RuntimeException('Not within the scope of an event loop driver');
+        }
+    }
+
     /**
      * Disable construction as this is a static class.
      */