@@ -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')); |
@@ -103,11 +103,11 @@ discard block |
||
103 | 103 | $args = [$key, $star, $stop]; |
104 | 104 | if ($withScores) { |
105 | 105 | $args[] = 'WITHSCORES'; |
106 | - return $this->dispatch(Builder::build($command, $args))->then(function ($value) { |
|
106 | + return $this->dispatch(Builder::build($command, $args))->then(function($value) { |
|
107 | 107 | $len = count($value); |
108 | 108 | $ret = []; |
109 | - for ($i=0; $i<$len; $i+=2) { |
|
110 | - $ret[$value[$i]] = $value[$i+1]; |
|
109 | + for ($i = 0; $i < $len; $i += 2) { |
|
110 | + $ret[$value[$i]] = $value[$i + 1]; |
|
111 | 111 | } |
112 | 112 | return $ret; |
113 | 113 | }); |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | { |
125 | 125 | $command = Enum::ZRANGEBYLEX; |
126 | 126 | $args = [$key, $min, $max]; |
127 | - $args = array_merge($args,$options); |
|
127 | + $args = array_merge($args, $options); |
|
128 | 128 | |
129 | 129 | return $this->dispatch(Builder::build($command, $args)); |
130 | 130 | } |
@@ -136,8 +136,8 @@ discard block |
||
136 | 136 | public function zRevRangeByLex($key, $max, $min, array $options = []) |
137 | 137 | { |
138 | 138 | $command = Enum::ZREVRANGEBYLEX; |
139 | - $args = [$key, $max,$min]; |
|
140 | - $args = array_merge($args,$options); |
|
139 | + $args = [$key, $max, $min]; |
|
140 | + $args = array_merge($args, $options); |
|
141 | 141 | |
142 | 142 | return $this->dispatch(Builder::build($command, $args)); |
143 | 143 | } |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | public function zRangeByScore($key, $min, $max, array $options = []) |
150 | 150 | { |
151 | 151 | $command = Enum::ZRANGEBYSCORE; |
152 | - $args = [$key, $min,$max]; |
|
152 | + $args = [$key, $min, $max]; |
|
153 | 153 | $args = array_merge($args, $options); |
154 | 154 | |
155 | 155 | return $this->dispatch(Builder::build($command, $args)); |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | public function zRank($key, $member) |
163 | 163 | { |
164 | 164 | $command = Enum::ZRANK; |
165 | - $args = [$key,$member]; |
|
165 | + $args = [$key, $member]; |
|
166 | 166 | |
167 | 167 | return $this->dispatch(Builder::build($command, $args)); |
168 | 168 | } |
@@ -200,7 +200,7 @@ discard block |
||
200 | 200 | public function zRemRangeByRank($key, $start, $stop) |
201 | 201 | { |
202 | 202 | $command = Enum::ZREMRANGEBYRANK; |
203 | - $args = [$key, $start,$stop]; |
|
203 | + $args = [$key, $start, $stop]; |
|
204 | 204 | |
205 | 205 | return $this->dispatch(Builder::build($command, $args)); |
206 | 206 | } |
@@ -238,7 +238,7 @@ discard block |
||
238 | 238 | public function zRevRangeByScore($key, $max, $min, array $options = []) |
239 | 239 | { |
240 | 240 | $command = Enum::ZREVRANGEBYSCORE; |
241 | - $args = [$key,$max,$min]; |
|
241 | + $args = [$key, $max, $min]; |
|
242 | 242 | $args = array_merge($args, $options); |
243 | 243 | |
244 | 244 | return $this->dispatch(Builder::build($command, $args)); |
@@ -251,7 +251,7 @@ discard block |
||
251 | 251 | public function zRevRank($key, $member) |
252 | 252 | { |
253 | 253 | $command = Enum::ZREVRANK; |
254 | - $args = [$key,$member]; |
|
254 | + $args = [$key, $member]; |
|
255 | 255 | |
256 | 256 | return $this->dispatch(Builder::build($command, $args)); |
257 | 257 | } |
@@ -263,7 +263,7 @@ discard block |
||
263 | 263 | public function zScore($key, $member) |
264 | 264 | { |
265 | 265 | $command = Enum::ZSCORE; |
266 | - $args = [$key,$member]; |
|
266 | + $args = [$key, $member]; |
|
267 | 267 | |
268 | 268 | return $this->dispatch(Builder::build($command, $args)); |
269 | 269 | } |
@@ -276,7 +276,7 @@ discard block |
||
276 | 276 | { |
277 | 277 | // TODO: Implement zScan() method. |
278 | 278 | $command = Enum::ZSCAN; |
279 | - $args = [$key , $cursor]; |
|
279 | + $args = [$key, $cursor]; |
|
280 | 280 | $args = array_merge($args, $options); |
281 | 281 | |
282 | 282 | return $this->dispatch(Builder::build($command, $args)); |