@@ -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 | } |