Upgraded to RxPHP 2.0

Author: WyriHaximus

composer.lock

@@ -12,8 +12,8 @@
 $config = require 'resolve_config.php';
 
 $client = AsyncClient::create($loop, $config['baseUrl'], $config['username'], $config['password']);
-$connections = $client->connections()->subscribe(new CallbackObserver(function (ConnectionInterface $connection) {
+$connections = $client->connections()->subscribe(function (ConnectionInterface $connection) {
     resource_pretty_print($connection);
-}));
+});
 
 $loop->run();

examples/connections-async.php

@@ -1,19 +1,18 @@
 <?php declare(strict_types=1);
 
 use ApiClients\Client\RabbitMQ\Management\AsyncClient;
-use function ApiClients\Foundation\resource_pretty_print;
 use ApiClients\Client\RabbitMQ\Management\Resource\QueueInterface;
 use React\EventLoop\Factory;
-use Rx\Observer\CallbackObserver;
+use function ApiClients\Foundation\resource_pretty_print;
 
 require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
 
 $loop = Factory::create();
 $config = require 'resolve_config.php';
 
 $client = AsyncClient::create($loop, $config['baseUrl'], $config['username'], $config['password']);
-$queues = $client->queues()->subscribe(new CallbackObserver(function (QueueInterface $queue) {
+$queues = $client->queues()->subscribe(function (QueueInterface $queue) {
     resource_pretty_print($queue);
-}));
+});
 
 $loop->run();

examples/queues-async.php

@@ -1,10 +1,8 @@
 <?php declare(strict_types=1);
 
 use ApiClients\Client\RabbitMQ\Management\AsyncClient;
-use function ApiClients\Foundation\resource_pretty_print;
 use ApiClients\Client\RabbitMQ\Management\Resource\QueueInterface;
 use React\EventLoop\Factory;
-use Rx\Observer\CallbackObserver;
 
 require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
 
@@ -18,9 +16,9 @@
 $client = AsyncClient::create($loop, $config['baseUrl'], $config['username'], $config['password']);
 $client->queues(1)->filter(function (QueueInterface $queue) {
     return strpos($queue->name(), 'amq.gen') !== 0;
-})->subscribe(new CallbackObserver(function (QueueInterface $queue) use (&$queues) {
+})->subscribe(function (QueueInterface $queue) use (&$queues) {
     $queues[$queue->name()] = $queue->messageStats()->deliverDetails()->rate();
-}));
+});
 
 $loop->addPeriodicTimer(1, function () use (&$height, &$length, &$queues) {
     for ($i = 0; $i < $height; $i++) {