@@ -54,7 +54,7 @@ |
||
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() |
@@ -71,7 +71,7 @@ |
||
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 |
@@ -62,8 +62,8 @@ discard block |
||
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 |
||
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 |
||
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')); |