Merge pull request #5 from davidwdan/examples

Make async examples more declarative

Author: WyriHaximus

examples/bitstamp-async.php

@@ -2,7 +2,6 @@
 
 use ApiClients\Client\Pusher\Event;
 use React\EventLoop\Factory;
-use Rx\Observer\CallbackObserver;
 use ApiClients\Client\Pusher\AsyncClient;
 
 require dirname(__DIR__) . DIRECTORY_SEPARATOR . 'vendor/autoload.php';
@@ -15,13 +14,17 @@
  */
 $client = AsyncClient::create($loop, 'de504dc5763aeef9ff52');
 
-$channelitems = array('live_trades','live_trades_xrpusd');
-foreach ($channelitems as $channelitem) {
-    $client->channel($channelitem)->subscribe(function (Event $event) {
-        echo 'Channel: '. $event->getChannel(). PHP_EOL;
-        echo 'Event: '. $event->getEvent(). PHP_EOL;
-        echo 'Data: '. print_r($event->getData(),1). PHP_EOL;
+$channelitems = array('live_trades', 'live_trades_xrpusd');
+
+$channels = Rx\Observable::fromArray($channelitems)
+    ->flatMap(function ($channelitem) use ($client) {
+        return $client->channel($channelitem);
     });
-}
+
+$channels->subscribe(function (Event $event) {
+    echo 'Channel: ' . $event->getChannel() . PHP_EOL;
+    echo 'Event: ' . $event->getEvent() . PHP_EOL;
+    echo 'Data: ' . print_r($event->getData(), 1) . PHP_EOL;
+});
 
 $loop->run();

examples/reddit-async.php

@@ -14,22 +14,24 @@
  */
 $client = AsyncClient::create($loop, require 'reddit.key.php');
 
-$subReddits = $argv;
-array_shift($subReddits);
-foreach ($subReddits as $subReddit) {
-    $client->channel($subReddit)->subscribe(
-        function (Event $event) {
-            echo 'Channel: ', $event->getChannel(), PHP_EOL;
-            echo 'Event: ', $event->getEvent(), PHP_EOL;
-            echo 'Data: ', json_encode($event->getData()), PHP_EOL;
-        },
-        function ($e) {
-            echo (string)$e;
-        },
-        function () {
-            echo 'Done!', PHP_EOL;
-        }
-    );
-}
+$subReddits = \Rx\Observable::fromArray($argv)
+    ->skip(1)
+    ->flatMap(function ($subReddit) use ($client) {
+        return $client->channel($subReddit);
+    });
+
+$subReddits->subscribe(
+    function (Event $event) {
+        echo 'Channel: ', $event->getChannel(), PHP_EOL;
+        echo 'Event: ', $event->getEvent(), PHP_EOL;
+        echo 'Data: ', json_encode($event->getData()), PHP_EOL;
+    },
+    function ($e) {
+        echo (string)$e;
+    },
+    function () {
+        echo 'Done!', PHP_EOL;
+    }
+);
 
 $loop->run();