Merge pull request clue#21 from clue/data

Rename "message" event to "data" event

Author: clue

examples/cli.php

@@ -18,7 +18,7 @@
 $factory->createClient()->then(function (Client $client) use ($loop) {
     echo '# connected! Entering interactive mode, hit CTRL-D to quit' . PHP_EOL;
 
-    $client->on('message', function (ModelInterface $data) {
+    $client->on('data', function (ModelInterface $data) {
         if ($data instanceof ErrorReply) {
             echo '# error reply: ' . $data->getMessage() . PHP_EOL;
         } else {

src/Client.php

@@ -9,7 +9,7 @@
 /**
  * Simple interface for executing redis commands
  *
- * @event message(ModelInterface $model, Client $thisClient)
+ * @event data(ModelInterface $messageModel, Client $thisClient)
  * @event close()
  */
 interface Client extends EventEmitterInterface

src/StreamingClient.php

@@ -83,7 +83,7 @@ public function __call($name, $args)
 
     public function handleMessage(ModelInterface $message)
     {
-        $this->emit('message', array($message, $this));
+        $this->emit('data', array($message, $this));
 
         if (!$this->requests) {
             throw new UnderflowException('Unexpected reply received, no matching request found');

tests/StreamingClientTest.php

@@ -55,16 +55,16 @@ public function testReceiveParseErrorEmitsErrorEvent()
 
     public function testReceiveMessageEmitsEvent()
     {
-        $this->client->on('message', $this->expectCallableOnce());
+        $this->client->on('data', $this->expectCallableOnce());
 
         $this->parser->expects($this->once())->method('pushIncoming')->with($this->equalTo('message'))->will($this->returnValue(array(new IntegerReply(2))));
         $this->stream->emit('data', array('message'));
     }
 
     public function testReceiveThrowMessageEmitsErrorEvent()
     {
-        $this->client->on('message', $this->expectCallableOnce());
-        $this->client->on('message', function() {
+        $this->client->on('data', $this->expectCallableOnce());
+        $this->client->on('data', function() {
             throw new UnderflowException();
         });