@@ -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')); |