Use the Voryx event loop instead of the interop

src/Client.php

@@ -2,7 +2,6 @@
 
 namespace Rx\Thruway;
 
-use Rx\Observer\CallbackObserver;
 use Rx\Scheduler;
 use Rx\Thruway\Subject\SessionReplaySubject;
 use Rx\Thruway\Subject\WebSocketSubject;

src/Subject/WebSocketSubject.php

@@ -27,7 +27,7 @@ public function __construct(string $url, array $protocols = [], Subject $openObs
         $this->openObserver  = $openObserver;
         $this->closeObserver = $closeObserver;
         $this->serializer    = new JsonSerializer();
-        $this->loop          = new AsyncInteropLoop();
+        $this->loop          = \EventLoop\getLoop();
         $this->output        = new Subject();
     }
 

tests/bootstrap.php

@@ -25,4 +25,6 @@
  * The default scheduler is the EventLoopScheduler, which is asynchronous.
  * For testing we need to block at `subscribe`, so we need to switch the default to the ImmediateScheduler.
  */
-\Rx\Scheduler::setDefault(new \Rx\Scheduler\ImmediateScheduler());
+\Rx\Scheduler::setDefaultFactory(function () {
+    return new \Rx\Scheduler\ImmediateScheduler();
+});