Updated to api-clients/rx 2.1 with observableFromArray

Author: WyriHaximus

composer.json

@@ -11,7 +11,7 @@
   ],
   "require": {
     "php": "^7.0",
-    "api-clients/client-services": "^1.0",
+    "api-clients/client-services": "^1.1",
     "api-clients/foundation": "dev-master",
     "api-clients/middleware-json": "^1.0",
     "api-clients/middleware-user-agent": "^1.0",

composer.lock

@@ -7,6 +7,7 @@
 use ApiClients\Foundation\Factory;
 use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateCommand;
 use ApiClients\Foundation\Transport\CommandBus\Command\SimpleRequestCommand;
+use function ApiClients\Tools\Rx\observableFromArray;
 use Psr\Http\Message\ResponseInterface;
 use React\EventLoop\LoopInterface;
 use React\Promise\PromiseInterface;
@@ -89,7 +90,7 @@ public function queues(int $interval = null): ObservableInterface
             return Promise::toObservable($this->client->handle(
                 new SimpleRequestCommand('queues')
             ))->flatMap(function (ResponseInterface $response) {
-                return Observable::fromArray($response->getBody()->getJson());
+                return observableFromArray($response->getBody()->getJson());
             })->flatMap(function ($queue) {
                 return Promise::toObservable($this->client->handle(
                     new HydrateCommand('Queue', $queue)
@@ -111,7 +112,7 @@ public function connections(): ObservableInterface
         return Promise::toObservable($this->client->handle(
             new SimpleRequestCommand('connections')
         ))->flatMap(function (ResponseInterface $response) {
-            return Observable::fromArray($response->getBody()->getJson());
+            return observableFromArray($response->getBody()->getJson());
         })->flatMap(function ($connection) {
             return Promise::toObservable($this->client->handle(
                 new HydrateCommand('Connection', $connection)