@@ -47,7 +47,8 @@ discard block |
||
| 47 | 47 | $command = Enum::BITFIELD; |
| 48 | 48 | $subCommand = strtoupper($subCommand); |
| 49 | 49 | //TODO: control flow improvement |
| 50 | - switch ($subCommand) { |
|
| 50 | + switch ($subCommand) |
|
| 51 | + { |
|
| 51 | 52 | case 'GET' : { |
| 52 | 53 | @list ($type, $offset) = $param; |
| 53 | 54 | $args = [$key, $subCommand, $type, $offset]; |
@@ -305,8 +306,10 @@ discard block |
||
| 305 | 306 | //TODO: change the param $kvMap to ...$kv,cauz map not allow duplicate key |
| 306 | 307 | $command = Enum::MSET; |
| 307 | 308 | $args = []; |
| 308 | - if (!empty($kvMap)) { |
|
| 309 | - foreach ($kvMap as $key => $val) { |
|
| 309 | + if (!empty($kvMap)) |
|
| 310 | + { |
|
| 311 | + foreach ($kvMap as $key => $val) |
|
| 312 | + { |
|
| 310 | 313 | $args[] = $key; |
| 311 | 314 | $args[] = $val; |
| 312 | 315 | } |
@@ -323,8 +326,10 @@ discard block |
||
| 323 | 326 | { |
| 324 | 327 | $command = Enum::MSETNX; |
| 325 | 328 | $args = []; |
| 326 | - if (!empty($kvMap)) { |
|
| 327 | - foreach ($kvMap as $key => $val) { |
|
| 329 | + if (!empty($kvMap)) |
|
| 330 | + { |
|
| 331 | + foreach ($kvMap as $key => $val) |
|
| 332 | + { |
|
| 328 | 333 | $args[] = $key; |
| 329 | 334 | $args[] = $val; |
| 330 | 335 | } |
@@ -49,10 +49,12 @@ discard block |
||
| 49 | 49 | $args = [$key]; |
| 50 | 50 | |
| 51 | 51 | return $this->dispatch(Builder::build($command, $args))->then(function ($value) { |
| 52 | - if (!empty($value)) { |
|
| 52 | + if (!empty($value)) |
|
| 53 | + { |
|
| 53 | 54 | $tmp = []; |
| 54 | 55 | $size = count($value); |
| 55 | - for ($i=0; $i<$size; $i+=2) { |
|
| 56 | + for ($i=0; $i<$size; $i+=2) |
|
| 57 | + { |
|
| 56 | 58 | $field = $value[$i]; |
| 57 | 59 | $val = $value[$i+1]; |
| 58 | 60 | $tmp[$field] = $val; |
@@ -134,8 +136,10 @@ discard block |
||
| 134 | 136 | //TODO: replace param $fvMap to ...$fvs,cauz hash map not allow duplicate key |
| 135 | 137 | $command = Enum::HMSET; |
| 136 | 138 | $args = [$key]; |
| 137 | - if (!empty($fvMap)) { |
|
| 138 | - foreach ($fvMap as $field => $value) { |
|
| 139 | + if (!empty($fvMap)) |
|
| 140 | + { |
|
| 141 | + foreach ($fvMap as $field => $value) |
|
| 142 | + { |
|
| 139 | 143 | $tmp[] = $field; |
| 140 | 144 | $tmp[] = $value; |
| 141 | 145 | } |
@@ -141,7 +141,7 @@ discard block |
||
| 141 | 141 | $this->isBeingDisconnected = false; |
| 142 | 142 | $this->stream = $stream; |
| 143 | 143 | $this->handleStart(); |
| 144 | - $this->emit('start', [ $this ]); |
|
| 144 | + $this->emit('start', [$this]); |
|
| 145 | 145 | |
| 146 | 146 | return true; |
| 147 | 147 | } |
@@ -170,7 +170,7 @@ discard block |
||
| 170 | 170 | |
| 171 | 171 | $this->reqs = []; |
| 172 | 172 | $this->handleStop(); |
| 173 | - $this->emit('stop', [ $this ]); |
|
| 173 | + $this->emit('stop', [$this]); |
|
| 174 | 174 | |
| 175 | 175 | return true; |
| 176 | 176 | } |
@@ -222,8 +222,8 @@ discard block |
||
| 222 | 222 | { |
| 223 | 223 | if ($this->stream !== null) |
| 224 | 224 | { |
| 225 | - $this->stream->on('data', [ $this, 'handleData' ]); |
|
| 226 | - $this->stream->on('close', [ $this, 'stop' ]); |
|
| 225 | + $this->stream->on('data', [$this, 'handleData']); |
|
| 226 | + $this->stream->on('close', [$this, 'stop']); |
|
| 227 | 227 | } |
| 228 | 228 | } |
| 229 | 229 | |
@@ -234,8 +234,8 @@ discard block |
||
| 234 | 234 | { |
| 235 | 235 | if ($this->stream !== null) |
| 236 | 236 | { |
| 237 | - $this->stream->removeListener('data', [ $this, 'handleData' ]); |
|
| 238 | - $this->stream->removeListener('close', [ $this, 'stop' ]); |
|
| 237 | + $this->stream->removeListener('data', [$this, 'handleData']); |
|
| 238 | + $this->stream->removeListener('close', [$this, 'stop']); |
|
| 239 | 239 | } |
| 240 | 240 | } |
| 241 | 241 | |
@@ -252,7 +252,7 @@ discard block |
||
| 252 | 252 | } |
| 253 | 253 | catch (ParserException $error) |
| 254 | 254 | { |
| 255 | - $this->emit('error', [ $this, $error ]); |
|
| 255 | + $this->emit('error', [$this, $error]); |
|
| 256 | 256 | $this->stop(); |
| 257 | 257 | return; |
| 258 | 258 | } |
@@ -265,7 +265,7 @@ discard block |
||
| 265 | 265 | } |
| 266 | 266 | catch (UnderflowException $error) |
| 267 | 267 | { |
| 268 | - $this->emit('error', [ $this, $error ]); |
|
| 268 | + $this->emit('error', [$this, $error]); |
|
| 269 | 269 | $this->stop(); |
| 270 | 270 | return; |
| 271 | 271 | } |