Changed namespace and added README.md

Author: davidwdan

README.md

@@ -0,0 +1,24 @@
+React Loop Interface For Async Interop Loop 
+======
+
+This library allows you use any [async-interop](https://packagist.org/providers/async-interop/event-loop-implementation) loop with any library that requires the [ReactPHP](https://github.com/reactphp/event-loop) loop.
+
+note: When all ReactPHP projects support the interop loop, this library will no longer be necessary.
+
+
+## Example
+
+```php
+    //Create your async-interop loop
+    
+    $loop = new \Voryx\React\AsyncInterop\Loop();
+    
+    //Then use your ReactPHP loop like you normally would
+    
+    $client = stream_socket_client('tcp://127.0.0.1:1337');
+    $conn = new React\Stream\Stream($client, $loop);
+    $conn->pipe(new React\Stream\Stream(STDOUT, $loop));
+    $conn->write("Hello World!\n");
+    
+    $loop->run();
+```

composer.json

@@ -23,7 +23,7 @@
     },
     "autoload": {
         "psr-4": {
-            "Voryx\\React\\EventLoop\\": "src/"
+            "Voryx\\React\\AsyncInterop\\": "src/"
         }
     }
 }

src/ReactAsyncInteropLoop.php renamed to src/Loop.php

@@ -1,12 +1,12 @@
 <?php
 
-namespace Voryx\React\EventLoop;
+namespace Voryx\React\AsyncInterop;
 
-use Interop\Async\Loop;
+use Interop\Async\Loop as InteropLoop;
 use React\EventLoop\LoopInterface;
 use React\EventLoop\Timer\TimerInterface;
 
-class ReactAsyncInteropLoop implements LoopInterface
+final class Loop implements LoopInterface
 {
     private $readStreams = [];
     private $writeStreams = [];
@@ -17,7 +17,7 @@ public function addReadStream($stream, callable $listener)
         if (isset($this->readStreams[$key])) {
             throw new \Exception('key set twice');
         }
-        $this->readStreams[$key] = Loop::get()->onReadable($stream, function () use ($listener, $stream) {
+        $this->readStreams[$key] = InteropLoop::get()->onReadable($stream, function () use ($listener, $stream) {
             $listener($stream);
         });
     }
@@ -30,7 +30,7 @@ public function addWriteStream($stream, callable $listener)
             throw new \Exception('key set twice');
         }
 
-        $this->writeStreams[$key] = Loop::get()->onWritable($stream, function () use ($listener, $stream) {
+        $this->writeStreams[$key] = InteropLoop::get()->onWritable($stream, function () use ($listener, $stream) {
             $listener($stream);
         });
     }
@@ -39,7 +39,7 @@ public function removeReadStream($stream)
     {
         $key = (int)$stream;
         if (isset($this->readStreams[$key])) {
-            Loop::get()->cancel($this->readStreams[$key]);
+            InteropLoop::get()->cancel($this->readStreams[$key]);
             unset($this->readStreams[$key]);
         }
     }
@@ -48,7 +48,7 @@ public function removeWriteStream($stream)
     {
         $key = (int)$stream;
         if (isset($this->writeStreams[$key])) {
-            Loop::get()->cancel($this->writeStreams[$key]);
+            InteropLoop::get()->cancel($this->writeStreams[$key]);
             unset($this->writeStreams[$key]);
         }
     }
@@ -66,11 +66,11 @@ private function addWrappedTimer($interval, callable $callback, $isPeriodic = fa
         };
         $millis          = $interval * 1000;
         if ($isPeriodic) {
-            $timerKey = Loop::get()->repeat($millis, $wrappedCallback);
+            $timerKey = InteropLoop::get()->repeat($millis, $wrappedCallback);
         } else {
-            $timerKey = Loop::get()->delay($millis, $wrappedCallback);
+            $timerKey = InteropLoop::get()->delay($millis, $wrappedCallback);
         }
-        $timer = new ReactAsyncInteropTimer(
+        $timer = new Timer(
             $timerKey,
             $interval,
             $callback,
@@ -102,7 +102,7 @@ public function isTimerActive(TimerInterface $timer)
 
     public function nextTick(callable $listener)
     {
-        Loop::get()->defer(function () use ($listener) {
+        InteropLoop::get()->defer(function () use ($listener) {
             $listener($this);
         });
     }
@@ -114,7 +114,7 @@ public function futureTick(callable $listener)
 
     public function tick()
     {
-        $loop = Loop::get();
+        $loop = InteropLoop::get();
 
         $loop->defer(function () use ($loop) {
             $loop->stop();
@@ -125,11 +125,11 @@ public function tick()
 
     public function run()
     {
-        Loop::get()->run();
+        InteropLoop::get()->run();
     }
 
     public function stop()
     {
-        Loop::get()->stop();
+        InteropLoop::get()->stop();
     }
 }

src/ReactAsyncInteropTimer.php renamed to src/Timer.php

@@ -1,12 +1,12 @@
 <?php
 
-namespace Voryx\React\EventLoop;
+namespace Voryx\React\AsyncInterop;
 
 use Interop\Async\Loop;
 use React\EventLoop\LoopInterface;
-use React\EventLoop\Timer\Timer;
+use React\EventLoop\Timer\Timer as ReactTimer;
 
-class ReactAsyncInteropTimer extends Timer
+final class Timer extends ReactTimer
 {
     private $timerKey;
 

tests/ReactAsyncInteropLoopTest.php

@@ -5,7 +5,6 @@
 use Interop\Async\Loop;
 use React\EventLoop\StreamSelectLoop;
 use React\Tests\EventLoop\AbstractLoopTest;
-use Voryx\React\EventLoop\ReactAsyncInteropLoop;
 use WyriHaximus\React\AsyncInteropLoop\ReactDriverFactory;
 
 class ReactAsyncInteropLoopTest extends AbstractLoopTest
@@ -16,7 +15,7 @@ public function createLoop()
         $driver = ReactDriverFactory::createFactoryFromLoop(StreamSelectLoop::class);
         Loop::setFactory($driver);
 
-        return new ReactAsyncInteropLoop();
+        return new \Voryx\React\AsyncInterop\Loop();
     }
 
     public function testRecursiveNextTick()

tests/ReactAsyncInteropLoopWithAmpTest.php

@@ -3,16 +3,16 @@
 namespace Voryx\Tests\React\EventLoop;
 
 use Amp\Loop\LoopFactory;
-use Interop\Async\Loop;
 use React\Tests\EventLoop\AbstractLoopTest;
-use Voryx\React\EventLoop\ReactAsyncInteropLoop;
+use Voryx\React\AsyncInterop\Loop;
+
 
 class ReactAsyncInteropLoopWithAmpTest extends AbstractLoopTest
 {
     public function createLoop()
     {
-        Loop::setFactory(new LoopFactory());
-        return new ReactAsyncInteropLoop();
+        \Interop\Async\Loop::setFactory(new LoopFactory());
+        return new Loop();
     }
 
     public function testRecursiveNextTick()