Merge pull request #3 from WyriHaximus/change-rxwebsocket-client

Change to Rx\Websocket client

Author: WyriHaximus

composer.json

@@ -9,8 +9,8 @@
   ],
   "require": {
     "php": "^7.0",
-    "ratchet/pawl": "^0.2.2",
-    "wyrihaximus/api-client": "dev-master"
+    "wyrihaximus/api-client": "dev-master",
+    "rx/websocket": "^0.9.2"
   },
   "require-dev": {
     "phpunit/phpunit": "^5.2.3",

composer.lock

@@ -18,10 +18,10 @@
 $subReddits = $argv;
 array_shift($subReddits);
 foreach ($subReddits as $subReddit) {
-    $client->subscribe($subReddit)->subscribe(new CallbackObserver(function ($event) {
-        echo 'Channel: ', $event['channel'], PHP_EOL;
-        echo 'Event: ', $event['event'], PHP_EOL;
-        echo 'Data: ', $event['data'], PHP_EOL;
+    $client->channel($subReddit)->subscribe(new CallbackObserver(function ($event) {
+        echo 'Channel: ', $event->channel, PHP_EOL;
+        echo 'Event: ', $event->event, PHP_EOL;
+        echo 'Data: ', $event->data, PHP_EOL;
     }));
 }