Merge pull request #17 from AndrewCarterUK/static-class-protot

Static Class Prototype

Author: AndrewCarterUK

src/EventLoop.php

@@ -0,0 +1,217 @@
+<?php
+
+namespace Interop\Async\EventLoop;
+
+final class EventLoop
+{
+    /**
+     * @var EventLoopDriver
+     */
+    private static $driver = null;
+
+    /**
+     * Execute a callback within the scope of an event loop driver.
+     *
+     * @param callable $callback The callback to execute
+     * @param EventLoopDriver $driver The event loop driver
+     *
+     * @return void
+     */
+    public static function execute(callable $callback, EventLoopDriver $driver)
+    {
+        $previousDriver = self::$driver;
+
+        self::$driver = $driver;
+
+        try {
+            $callback();
+
+            self::$driver->run();
+        } finally {
+            self::$driver = $previousDriver;
+        }
+    }
+
+    /**
+     * Retrieve the event loop driver that is in scope.
+     * 
+     * @return EventLoopDriver
+     */
+    public static function get()
+    {
+        if (null === self::$driver) {
+            throw new \RuntimeException('Not within the scope of an event loop driver');
+        }
+
+        return self::$driver;
+    }
+
+    /**
+     * Stop the event loop.
+     * 
+     * @return void
+     */
+    public static function stop()
+    {
+        self::get()->stop();
+    }
+
+    /**
+     * Defer the execution of a callback.
+     * 
+     * @param callable $callback The callback to defer.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function defer(callable $callback)
+    {
+        return self::get()->defer($callback);
+    }
+
+    /**
+     * Delay the execution of a callback. The time delay is approximate and accuracy is not guaranteed.
+     * 
+     * @param callable $callback The callback to delay.
+     * @param int $time The amount of time, in milliseconds, to delay the execution for.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function delay(callable $callback, $time)
+    {
+        return self::get()->delay($callback, $time);
+    }
+
+    /**
+     * Repeatedly execute a callback. The interval between executions is approximate and accuracy is not guaranteed.
+     * 
+     * @param callable $callback The callback to repeat.
+     * @param int $interval The time interval, in milliseconds, to wait between executions.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function repeat(callable $callback, $interval)
+    {
+        return self::get()->repeat($callback, $interval);
+    }
+
+    /**
+     * Execute a callback when a stream resource becomes readable.
+     * 
+     * @param resource $stream The stream to monitor.
+     * @param callable $callback The callback to execute.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function onReadable($stream, callable $callback)
+    {
+        return self::get()->onReadable($stream, $callback);
+    }
+
+    /**
+     * Execute a callback when a stream resource becomes writable.
+     * 
+     * @param resource $stream The stream to monitor.
+     * @param callable $callback The callback to execute.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function onWritable($stream, callable $callback)
+    {
+        return self::get()->onWritable($stream, $callback);
+    }
+
+    /**
+     * Execute a callback when a signal is received.
+     * 
+     * @param int $signo The signal number to monitor.
+     * @param callable $callback The callback to execute.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function onSignal($signo, callable $callback)
+    {
+        return self::get()->onSignal($signo, $callback);
+    }
+
+    /**
+     * Execute a callback when an error occurs.
+     * 
+     * @param callable $callback The callback to execute.
+     * 
+     * @return string An identifier that can be used to cancel, enable or disable the event.
+     */
+    public static function onError(callable $callback)
+    {
+        return self::get()->onError($callback);
+    }
+
+    /**
+     * Enable an event.
+     * 
+     * @param string $eventIdentifier The event identifier.
+     * 
+     * @return void
+     */
+    public static function enable($eventIdentifier)
+    {
+        self::get()->enable($eventIdentifier);
+    }
+
+    /**
+     * Disable an event.
+     * 
+     * @param string $eventIdentifier The event identifier.
+     * 
+     * @return void
+     */
+    public static function disable($eventIdentifier)
+    {
+        self::get()->disable($eventIdentifier);
+    }
+
+    /**
+     * Cancel an event.
+     * 
+     * @param string $eventIdentifier The event identifier.
+     * 
+     * @return void
+     */
+    public static function cancel($eventIdentifier)
+    {
+        self::get()->cancel($eventIdentifier);
+    }
+
+    /**
+     * Reference an event.
+     * 
+     * This will keep the event loop alive whilst the event is still being monitored. Events have this state by default.
+     * 
+     * @param string $eventIdentifier The event identifier.
+     * 
+     * @return void
+     */
+    public static function reference($eventIdentifier)
+    {
+        self::get()->reference($eventIdentifier);
+    }
+
+    /**
+     * Unreference an event.
+     * 
+     * The event loop should exit the run method when only unreferenced events are still being monitored. Events are all
+     * referenced by default.
+     * 
+     * @param string $eventIdentifier The event identifier.
+     * 
+     * @return void
+     */
+    public static function unreference($eventIdentifier)
+    {
+        self::get()->unreference($eventIdentifier);
+    }
+
+    /**
+     * Disable construction as this is a static class.
+     */
+    private function __construct() {}
+}