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