Skeleton for MONITOR command, forward "monitor" events

Author: clue

examples/monitor.php

@@ -0,0 +1,24 @@
+<?php
+
+use Clue\React\Redis\Client;
+use Clue\React\Redis\Factory;
+use Clue\Redis\Protocol\Model\StatusReply;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+$factory = new Factory($loop);
+
+$factory->createClient()->then(function (Client $client) {
+    $client->monitor()->then(function ($result) {
+        echo 'Now monitoring all commands' . PHP_EOL;
+    });
+
+    $client->on('monitor', function (StatusReply $message) {
+        echo 'Monitored: ' . $message->getValueNative() . PHP_EOL;
+    });
+
+    $client->echo('initial echo');
+});
+
+$loop->run();

src/Client.php

@@ -11,6 +11,8 @@
  *
  * @event data(ModelInterface $messageModel, Client $thisClient)
  * @event close()
+ *
+ * @event monitor(ModelInterface $statusModel)
  */
 interface Client extends EventEmitterInterface
 {

src/StreamingClient.php

@@ -14,6 +14,7 @@
 use React\Promise\Deferred;
 use Clue\Redis\Protocol\Model\ErrorReply;
 use Clue\Redis\Protocol\Model\ModelInterface;
+use Clue\Redis\Protocol\Model\StatusReply;
 
 class StreamingClient extends EventEmitter implements Client
 {
@@ -24,6 +25,8 @@ class StreamingClient extends EventEmitter implements Client
     private $ending = false;
     private $closed = false;
 
+    private $monitoring = false;
+
     public function __construct(Stream $stream, ParserInterface $parser = null, SerializerInterface $serializer = null)
     {
         if ($parser === null || $serializer === null) {
@@ -78,13 +81,25 @@ public function __call($name, $args)
             $this->requests []= $request;
         }
 
+        if (strtolower($name) === 'monitor') {
+            $monitoring =& $this->monitoring;
+            $request->then(function () use (&$monitoring) {
+                $monitoring = true;
+            });
+        }
+
         return $request->promise();
     }
 
     public function handleMessage(ModelInterface $message)
     {
         $this->emit('data', array($message, $this));
 
+        if ($this->monitoring && $message instanceof StatusReply) {
+            $this->emit('monitor', array($message, $this));
+            return;
+        }
+
         if (!$this->requests) {
             throw new UnderflowException('Unexpected reply received, no matching request found');
         }