Merge pull request #196 from mbonneau/event-loop-update

 Forward compatibility with react/event-loop 1.0 and 0.5 while still support 0.4

Author: davidwdan

composer.json

@@ -27,7 +27,7 @@
         "satooshi/php-coveralls": "~1.0",
         "phpunit/phpcov": "^3.1",
         "phpunit/phpunit": "^5.7",
-        "react/event-loop": "^0.4.2"
+        "react/event-loop": "^1.0 || ^0.5 || ^0.4.2"
     },
     "suggest": {
         "react/event-loop": "Used for scheduling async operations"

demo/subscribeOn/subscribeOn.php

@@ -18,10 +18,10 @@
     // Change scheduler for here
     $timer = $loop->addTimer(0.001, $handler);
 
-    return new CallbackDisposable(function () use ($timer) {
+    return new CallbackDisposable(function () use ($loop, $timer) {
         // And change scheduler for here
         if ($timer) {
-            $timer->cancel();
+            $loop->cancelTimer($timer);
         }
     });
 });

src/Scheduler/EventLoopScheduler.php

@@ -29,8 +29,8 @@ public function __construct($timerCallableOrLoop)
         $this->delayCallback = $timerCallableOrLoop instanceof LoopInterface ?
             function ($ms, $callable) use ($timerCallableOrLoop) {
                 $timer = $timerCallableOrLoop->addTimer($ms / 1000, $callable);
-                return new CallbackDisposable(function () use ($timer) {
-                    $timer->cancel();
+                return new CallbackDisposable(function () use ($timer, $timerCallableOrLoop) {
+                    $timerCallableOrLoop->cancelTimer($timer);
                 });
             } :
             $timerCallableOrLoop;

test/Rx/Scheduler/EventLoopSchedulerTest.php

@@ -147,8 +147,8 @@ public function testScheduledItemsFromOutsideOfSchedulerDontCreateExtraTimers()
                 $timersExecuted++;
                 $action();
             });
-            return new CallbackDisposable(function () use ($timer) {
-                $timer->cancel();
+            return new CallbackDisposable(function () use ($loop, $timer) {
+                $loop->cancelTimer($timer);
             });
         });
 
@@ -176,8 +176,8 @@ public function testMultipleSchedulesFromOutsideInSameTickDontCreateExtraTimers(
                 $timersExecuted++;
                 $action();
             });
-            return new CallbackDisposable(function () use ($timer) {
-                $timer->cancel();
+            return new CallbackDisposable(function () use ($loop, $timer) {
+                $loop->cancelTimer($timer);
             });
         });
 
@@ -206,8 +206,8 @@ public function testThatStuffScheduledWayInTheFutureDoesntKeepTheLoopRunningIfDi
                 $timersExecuted++;
                 $action();
             });
-            return new CallbackDisposable(function () use ($timer) {
-                $timer->cancel();
+            return new CallbackDisposable(function () use ($loop, $timer) {
+                $loop->cancelTimer($timer);
             });
         });