iPublikuj / websockets-zmq

src/IPub/WebSocketsZMQ/Consumer/Consumer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
  * @date           28.02.17
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace IPub\WebSocketsZMQ\Consumer;
 
@@ -92,7 +92,7 @@ 
 			$this->configuration->getPort()
 		));
 
-		$this->socket->bind($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort());
+		$this->socket->bind($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort());
 
 		$this->socket->on('message', function ($data) use ($application) {
 			try {

src/IPub/WebSocketsZMQ/DI/WebSocketsZMQExtension.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
  * @date           01.03.17
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace IPub\WebSocketsZMQ\DI;
 

src/IPub/WebSocketsZMQ/Configuration.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
  * @date           28.02.17
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace IPub\WebSocketsZMQ;
 

src/IPub/WebSocketsZMQ/Pusher/Pusher.php

Spacing +3 added lines, -3 removed lines

@@ -12,7 +12,7 @@ 
  * @date           01.03.17
  */
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace IPub\WebSocketsZMQ\Pusher;
 
@@ -86,7 +86,7 @@ 
 			return;
 		}
 
-		$this->socket->disconnect($this->configuration->getHost() . ':' . $this->configuration->getPort());
+		$this->socket->disconnect($this->configuration->getHost().':'.$this->configuration->getPort());
 	}
 
 	/**
@@ -108,7 +108,7 @@ 
 			$context = new ZMQContext(1, $this->configuration->isPersistent());
 
 			$this->socket = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
-			$this->socket->connect($this->configuration->getProtocol() . '://' . $this->configuration->getHost() . ':' . $this->configuration->getPort());
+			$this->socket->connect($this->configuration->getProtocol().'://'.$this->configuration->getHost().':'.$this->configuration->getPort());
 
 			$this->setConnected();
 		}