@@ -17,17 +17,13 @@ |
||
| 17 | 17 | namespace IPub\MQTTClient\Client; |
| 18 | 18 | |
| 19 | 19 | use Closure; |
| 20 | - |
|
| 21 | 20 | use Nette; |
| 22 | - |
|
| 23 | 21 | use React\EventLoop; |
| 24 | 22 | use React\Dns; |
| 25 | 23 | use React\Promise; |
| 26 | 24 | use React\Socket; |
| 27 | 25 | use React\Stream; |
| 28 | - |
|
| 29 | 26 | use BinSoul\Net\Mqtt; |
| 30 | - |
|
| 31 | 27 | use IPub\MQTTClient\Configuration; |
| 32 | 28 | use IPub\MQTTClient\Exceptions; |
| 33 | 29 | use IPub\MQTTClient\Flow; |
@@ -20,11 +20,8 @@ |
||
| 20 | 20 | use Symfony\Component\Console\Input; |
| 21 | 21 | use Symfony\Component\Console\Style; |
| 22 | 22 | use Symfony\Component\Console\Output; |
| 23 | - |
|
| 24 | 23 | use Psr\Log; |
| 25 | - |
|
| 26 | 24 | use BinSoul\Net\Mqtt; |
| 27 | - |
|
| 28 | 25 | use IPub\MQTTClient\Client; |
| 29 | 26 | use IPub\MQTTClient\Exceptions; |
| 30 | 27 | use IPub\MQTTClient\Logger; |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | * @date 14.03.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\Configuration; |
| 18 | 18 | |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @date 14.03.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\Configuration; |
| 18 | 18 | |
@@ -113,10 +113,10 @@ discard block |
||
| 113 | 113 | public function getUri() : string |
| 114 | 114 | { |
| 115 | 115 | if ($this->httpHost !== NULL) { |
| 116 | - return $this->httpHost . ':' . $this->port; |
|
| 116 | + return $this->httpHost.':'.$this->port; |
|
| 117 | 117 | |
| 118 | 118 | } elseif ($this->address !== NULL) { |
| 119 | - return $this->address . ':' . $this->port; |
|
| 119 | + return $this->address.':'.$this->port; |
|
| 120 | 120 | } |
| 121 | 121 | |
| 122 | 122 | throw new Exceptions\InvalidStateException('Broker http host or address is not specified'); |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @date 12.03.17 |
| 13 | 13 | */ |
| 14 | 14 | |
| 15 | -declare(strict_types = 1); |
|
| 15 | +declare(strict_types=1); |
|
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\DI; |
| 18 | 18 | |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | ]; |
| 141 | 141 | |
| 142 | 142 | foreach ($commands as $name => $cmd) { |
| 143 | - $builder->addDefinition($this->prefix('commands.' . lcfirst($name))) |
|
| 143 | + $builder->addDefinition($this->prefix('commands.'.lcfirst($name))) |
|
| 144 | 144 | ->setType($cmd); |
| 145 | 145 | } |
| 146 | 146 | } |