@@ -98,7 +98,7 @@ |
||
| 98 | 98 | protected function implodeArrayToAString(array $input) |
| 99 | 99 | { |
| 100 | 100 | $output = implode(', ', array_map( |
| 101 | - function ($v, $k) { |
|
| 101 | + function($v, $k) { |
|
| 102 | 102 | if (is_array($v)) { |
| 103 | 103 | return $k.'[]='.implode('&'.$k.'[]=', $v); |
| 104 | 104 | } else { |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | ]; |
| 71 | 71 | |
| 72 | 72 | // persist all in a transaction |
| 73 | - $this->client->transaction($options, function ($tx) use ($arrayChunks, $list, $ttl, $listUuid, $items, $chunkSize) { |
|
| 73 | + $this->client->transaction($options, function($tx) use ($arrayChunks, $list, $ttl, $listUuid, $items, $chunkSize) { |
|
| 74 | 74 | foreach ($arrayChunks as $chunkNumber => $item) { |
| 75 | 75 | foreach ($item as $key => $element) { |
| 76 | 76 | $listChunkUuid = $listUuid.self::SEPARATOR.self::CHUNK.'-'.($chunkNumber + 1); |
@@ -153,7 +153,7 @@ discard block |
||
| 153 | 153 | ]; |
| 154 | 154 | |
| 155 | 155 | // delete in a transaction |
| 156 | - $this->client->transaction($options, function ($tx) use ($listUuid, $numberOfChunks, $chunkSize, $elementUuid) { |
|
| 156 | + $this->client->transaction($options, function($tx) use ($listUuid, $numberOfChunks, $chunkSize, $elementUuid) { |
|
| 157 | 157 | for ($i = 1; $i <= $numberOfChunks; ++$i) { |
| 158 | 158 | $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i; |
| 159 | 159 | $chunk = $this->client->hgetall($chunkNumber); |
@@ -314,7 +314,7 @@ discard block |
||
| 314 | 314 | ]; |
| 315 | 315 | |
| 316 | 316 | // persist in a transaction |
| 317 | - $this->client->transaction($options, function ($tx) use ($chunkNumber, $numberOfChunks, $chunkSize, $listUuid, $elementUuid, $body) { |
|
| 317 | + $this->client->transaction($options, function($tx) use ($chunkNumber, $numberOfChunks, $chunkSize, $listUuid, $elementUuid, $body) { |
|
| 318 | 318 | if (($chunkSize - count($tx->hgetall($chunkNumber))) === 0) { |
| 319 | 319 | ++$numberOfChunks; |
| 320 | 320 | $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$numberOfChunks; |
@@ -371,7 +371,7 @@ discard block |
||
| 371 | 371 | ]; |
| 372 | 372 | |
| 373 | 373 | // persist in a transaction |
| 374 | - $this->client->transaction($options, function ($tx) use ($numberOfChunks, $listUuid, $elementUuid, $data) { |
|
| 374 | + $this->client->transaction($options, function($tx) use ($numberOfChunks, $listUuid, $elementUuid, $data) { |
|
| 375 | 375 | for ($i = 1; $i <= $numberOfChunks; ++$i) { |
| 376 | 376 | $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i; |
| 377 | 377 | $chunk = $this->client->hgetall($chunkNumber); |
@@ -430,7 +430,7 @@ discard block |
||
| 430 | 430 | ]; |
| 431 | 431 | |
| 432 | 432 | // persist in a transaction |
| 433 | - $this->client->transaction($options, function ($tx) use ($numberOfChunks, $listUuid, $ttl) { |
|
| 433 | + $this->client->transaction($options, function($tx) use ($numberOfChunks, $listUuid, $ttl) { |
|
| 434 | 434 | for ($i = 1; $i <= $numberOfChunks; ++$i) { |
| 435 | 435 | $tx->expire( |
| 436 | 436 | (string) $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i, |
@@ -40,7 +40,7 @@ |
||
| 40 | 40 | |
| 41 | 41 | protected function execute(InputInterface $input, OutputInterface $output) |
| 42 | 42 | { |
| 43 | - if($this->driver !== 'pdo'){ |
|
| 43 | + if ($this->driver !== 'pdo') { |
|
| 44 | 44 | throw new \Exception('This command is avaliable only with PDO driver'); |
| 45 | 45 | } |
| 46 | 46 | |
@@ -40,7 +40,7 @@ |
||
| 40 | 40 | |
| 41 | 41 | protected function execute(InputInterface $input, OutputInterface $output) |
| 42 | 42 | { |
| 43 | - if($this->driver !== 'pdo'){ |
|
| 43 | + if ($this->driver !== 'pdo') { |
|
| 44 | 44 | throw new \Exception('This command is avaliable only with PDO driver'); |
| 45 | 45 | } |
| 46 | 46 | |