@@ -17,15 +17,12 @@  | 
                                                    ||
| 17 | 17 | namespace IPub\MQTTClient\Client;  | 
                                                        
| 18 | 18 | |
| 19 | 19 | use Nette;  | 
                                                        
| 20 | -  | 
                                                        |
| 21 | 20 | use React\EventLoop;  | 
                                                        
| 22 | 21 | use React\Dns;  | 
                                                        
| 23 | 22 | use React\Promise;  | 
                                                        
| 24 | 23 | use React\Socket;  | 
                                                        
| 25 | 24 | use React\Stream;  | 
                                                        
| 26 | -  | 
                                                        |
| 27 | 25 | use BinSoul\Net\Mqtt;  | 
                                                        
| 28 | -  | 
                                                        |
| 29 | 26 | use IPub\MQTTClient\Exceptions;  | 
                                                        
| 30 | 27 | use IPub\MQTTClient\Flow;  | 
                                                        
| 31 | 28 | |
@@ -12,7 +12,7 @@  | 
                                                    ||
| 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\Client;  | 
                                                        
| 18 | 18 | |
@@ -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\Logger;  | 
                                                        
| 30 | 27 | |
@@ -12,7 +12,7 @@  | 
                                                    ||
| 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\Commands;  | 
                                                        
| 18 | 18 | |
@@ -17,7 +17,6 @@  | 
                                                    ||
| 17 | 17 | namespace IPub\MQTTClient\Flow;  | 
                                                        
| 18 | 18 | |
| 19 | 19 | use React\Promise;  | 
                                                        
| 20 | -  | 
                                                        |
| 21 | 20 | use BinSoul\Net\Mqtt;  | 
                                                        
| 22 | 21 | |
| 23 | 22 | /**  | 
                                                        
@@ -12,7 +12,7 @@  | 
                                                    ||
| 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\Flow;  | 
                                                        
| 18 | 18 | |
@@ -130,6 +130,7 @@  | 
                                                    ||
| 130 | 130 | |
| 131 | 131 | /**  | 
                                                        
| 132 | 132 |  	 * {@inheritdoc} | 
                                                        
| 133 | + * @return string|null  | 
                                                        |
| 133 | 134 | */  | 
                                                        
| 134 | 135 | public function getErrorMessage()  | 
                                                        
| 135 | 136 |  	{ | 
                                                        
@@ -17,9 +17,7 @@  | 
                                                    ||
| 17 | 17 | namespace IPub\MQTTClient\Logger;  | 
                                                        
| 18 | 18 | |
| 19 | 19 | use Nette;  | 
                                                        
| 20 | -  | 
                                                        |
| 21 | 20 | use Psr\Log;  | 
                                                        
| 22 | -  | 
                                                        |
| 23 | 21 | use IPub;  | 
                                                        
| 24 | 22 | |
| 25 | 23 | /**  | 
                                                        
@@ -12,7 +12,7 @@ discard block  | 
                                                    ||
| 12 | 12 | * @date 26.02.17  | 
                                                        
| 13 | 13 | */  | 
                                                        
| 14 | 14 | |
| 15 | -declare(strict_types = 1);  | 
                                                        |
| 15 | +declare(strict_types=1);  | 
                                                        |
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\Logger;  | 
                                                        
| 18 | 18 | |
@@ -196,7 +196,7 @@ discard block  | 
                                                    ||
| 196 | 196 | $this->formatter->writeln($message);  | 
                                                        
| 197 | 197 | |
| 198 | 198 |  		} else { | 
                                                        
| 199 | - echo $message . "\r\n";  | 
                                                        |
| 199 | + echo $message."\r\n";  | 
                                                        |
| 200 | 200 | }  | 
                                                        
| 201 | 201 | }  | 
                                                        
| 202 | 202 | }  | 
                                                        
@@ -17,7 +17,6 @@  | 
                                                    ||
| 17 | 17 | namespace IPub\MQTTClient\React;  | 
                                                        
| 18 | 18 | |
| 19 | 19 | use React\Promise;  | 
                                                        
| 20 | -  | 
                                                        |
| 21 | 20 | use BinSoul\Net\Mqtt;  | 
                                                        
| 22 | 21 | |
| 23 | 22 | /**  | 
                                                        
@@ -12,7 +12,7 @@  | 
                                                    ||
| 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\React;  | 
                                                        
| 18 | 18 | |
@@ -12,7 +12,7 @@  | 
                                                    ||
| 12 | 12 | * @date 26.02.17  | 
                                                        
| 13 | 13 | */  | 
                                                        
| 14 | 14 | |
| 15 | -declare(strict_types = 1);  | 
                                                        |
| 15 | +declare(strict_types=1);  | 
                                                        |
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\Logger\Formatter;  | 
                                                        
| 18 | 18 | |
@@ -12,7 +12,7 @@  | 
                                                    ||
| 12 | 12 | * @date 13.03.17  | 
                                                        
| 13 | 13 | */  | 
                                                        
| 14 | 14 | |
| 15 | -declare(strict_types = 1);  | 
                                                        |
| 15 | +declare(strict_types=1);  | 
                                                        |
| 16 | 16 | |
| 17 | 17 | namespace IPub\MQTTClient\Exceptions;  | 
                                                        
| 18 | 18 | |
@@ -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\Exceptions;  | 
                                                        
| 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\Client;  | 
                                                        
| 18 | 18 | |
@@ -115,10 +115,10 @@ discard block  | 
                                                    ||
| 115 | 115 | public function getUri() : string  | 
                                                        
| 116 | 116 |  	{ | 
                                                        
| 117 | 117 |  		if ($this->httpHost !== NULL) { | 
                                                        
| 118 | - return $this->httpHost .':'. $this->port;  | 
                                                        |
| 118 | + return $this->httpHost.':'.$this->port;  | 
                                                        |
| 119 | 119 | |
| 120 | 120 |  		} elseif ($this->address !== NULL) { | 
                                                        
| 121 | - return $this->address .':'. $this->port;  | 
                                                        |
| 121 | + return $this->address.':'.$this->port;  | 
                                                        |
| 122 | 122 | }  | 
                                                        
| 123 | 123 | |
| 124 | 124 |  		throw new Exceptions\InvalidStateException('Broker http host or address is not specified'); |