Update clue/redis-protocol to v0.3.0

Author: clue

composer.json

@@ -14,7 +14,7 @@
         "react/promise": "~1",
         "react/socket-client": "0.3.*",
         "react/event-loop": "0.3.*",
-        "clue/redis-protocol": "0.2.*"
+        "clue/redis-protocol": "0.3.*"
     },
     "autoload": {
         "psr-0": { "Clue\\Redis\\React": "src" }

composer.lock

@@ -27,7 +27,7 @@ public function __construct(Stream $stream, ParserInterface $parser = null, Seri
         if ($parser === null || $serializer === null) {
             $factory = new ProtocolFactory();
             if ($parser === null) {
-                $parser = $factory->createParser();
+                $parser = $factory->createResponseParser();
             }
             if ($serializer === null) {
                 $serializer = $factory->createSerializer();
@@ -37,17 +37,15 @@ public function __construct(Stream $stream, ParserInterface $parser = null, Seri
         $that = $this;
         $stream->on('data', function($chunk) use ($parser, $that) {
             try {
-                $parser->pushIncoming($chunk);
+                $models = $parser->pushIncoming($chunk);
             }
             catch (ParserException $error) {
                 $that->emit('error', array($error));
                 $that->close();
                 return;
             }
 
-            while ($parser->hasIncomingModel()) {
-                $data = $parser->popIncomingModel();
-
+            foreach ($models as $data) {
                 try {
                     $that->handleReply($data);
                 }
@@ -74,12 +72,7 @@ public function __call($name, $args)
             return When::reject(new RuntimeException('Connection closed'));
         }
 
-        $name = strtoupper($name);
-
-        /* Build the Redis unified protocol command */
-        array_unshift($args, $name);
-
-        $this->stream->write($this->serializer->createRequestMessage($args));
+        $this->stream->write($this->serializer->getRequestMessage($name, $args));
 
         $request = new Request($name);
         $this->requests []= $request;

src/Clue/Redis/React/Client.php

@@ -41,7 +41,7 @@ public function createClient($target = null)
         $protocol = $this->protocol;
 
         return $this->connect($target)->then(function (Stream $stream) use ($auth, $db, $protocol) {
-            $client = new Client($stream, $protocol->createParser(), $protocol->createSerializer());
+            $client = new Client($stream, $protocol->createResponseParser(), $protocol->createSerializer());
 
             return When::all(
                 array(