Merge pull request #38 from clue-labs/api

Consistent public API

Author: clue

src/Client.php

@@ -9,7 +9,7 @@
 /**
  * Simple interface for executing redis commands
  *
- * @event data(ModelInterface $messageModel, Client $thisClient)
+ * @event data(ModelInterface $messageModel)
  * @event error(Exception $error)
  * @event close()
  *
@@ -33,7 +33,7 @@ interface Client extends EventEmitterInterface
      *
      * @param string   $name
      * @param string[] $args
-     * @return PromiseInterface
+     * @return PromiseInterface Promise<mixed, Exception>
      */
     public function __call($name, $args);
 

src/StreamingClient.php

@@ -18,6 +18,9 @@
 use Clue\Redis\Protocol\Model\MultiBulkReply;
 use Clue\Redis\Protocol\Model\StatusReply;
 
+/**
+ * @internal
+ */
 class StreamingClient extends EventEmitter implements Client
 {
     private $stream;
@@ -122,7 +125,7 @@ public function __call($name, $args)
 
     public function handleMessage(ModelInterface $message)
     {
-        $this->emit('data', array($message, $this));
+        $this->emit('data', array($message));
 
         if ($this->monitoring && $this->isMonitorMessage($message)) {
             $this->emit('monitor', array($message));