Completed
Pull Request — master (#2)
by
unknown
02:18
created
src/Redis/Config.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -54,7 +54,7 @@
 block discarded – undo
54 54
         $this->host = $parts['host'];
55 55
         $this->port = $parts['port'];
56 56
         $this->auth = $auth;
57
-        $this->db =  $parts['db'];
57
+        $this->db = $parts['db'];
58 58
     }
59 59
 
60 60
     public function getHost()
Please login to merge, or discard this patch.
src/Redis/Redis.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -71,7 +71,7 @@
 block discarded – undo
71 71
         {
72 72
             $payload = $this->driver->commands($command);
73 73
 
74
-            $this->dispatcher->on('request', function () use ($payload) {
74
+            $this->dispatcher->on('request', function() use ($payload) {
75 75
                 $this->dispatcher->handleRequest($payload);
76 76
             });
77 77
 
Please login to merge, or discard this patch.
src/Redis/Dispatcher.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -62,8 +62,8 @@  discard block
 block discarded – undo
62 62
         $this->closed = false;
63 63
         $this->protocol = new Driver();
64 64
         $this->on('connect', [$this, 'handleConnect']);
65
-        $this->on('response',[$this, 'handleResponse']);
66
-        $this->on('disconnect',[$this, 'handleDisconnect']);
65
+        $this->on('response', [$this, 'handleResponse']);
66
+        $this->on('disconnect', [$this, 'handleDisconnect']);
67 67
         $this->on('close', [$this, 'handleClose']);
68 68
     }
69 69
 
@@ -120,7 +120,7 @@  discard block
 block discarded – undo
120 120
      */
121 121
     public function isEnding()
122 122
     {
123
-        return $this->ending? true: false;
123
+        return $this->ending ? true : false;
124 124
     }
125 125
 
126 126
     /**
@@ -227,7 +227,7 @@  discard block
 block discarded – undo
227 227
     {
228 228
         $this->ending = true;
229 229
         // reject all remaining requests in the queue
230
-        while($this->reqs) {
230
+        while ($this->reqs) {
231 231
             $req = array_shift($this->reqs);
232 232
             /* @var $req Deferred */
233 233
             $req->reject(new RuntimeException('Connection closing'));
Please login to merge, or discard this patch.