Updated JobLogHandler to RxPHP 2.0

Author: WyriHaximus

src/CommandBus/Handler/JobLogHandler.php

@@ -12,10 +12,7 @@
 use React\Promise\PromiseInterface;
 use Rx\Observable;
 use Rx\ObserverInterface;
-use Rx\SchedulerInterface;
-use function ApiClients\Tools\Rx\unwrapObservableFromPromise;
 use function React\Promise\resolve;
-use function WyriHaximus\React\futureFunctionPromise;
 
 final class JobLogHandler
 {
@@ -52,8 +49,7 @@ public function handle(JobLogCommand $command): PromiseInterface
             ApiSettings::PUSHER_KEY
         )->then(function (PusherAsyncClient $pusher) use ($command) {
             return resolve(Observable::create(function (
-                ObserverInterface $observer,
-                SchedulerInterface $scheduler
+                ObserverInterface $observer
             ) use (
                 $pusher,
                 $command
@@ -62,7 +58,7 @@ public function handle(JobLogCommand $command): PromiseInterface
                     return $event->getEvent() === 'job:log';
                 })->map(function (Event $event) {
                     return $this->hydrator->hydrate(LogLineInterface::HYDRATE_CLASS, $event->getData());
-                })->subscribeCallback(
+                })->subscribe(
                     function (LogLineInterface $line) use ($observer, &$subscription) {
                         $observer->onNext($line);
 
@@ -75,8 +71,7 @@ function ($error) use ($observer) {
                     },
                     function () use ($observer) {
                         $observer->onComplete();
-                    },
-                    $scheduler
+                    }
                 );
             }));
         });