alexpts / php-transports

src/UdpSocket.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
         $packages = $this->splitToChunks($message);
         $bytes = 0;
         foreach ($packages as $package) {
-            $bytes += (int)parent::write($package, $length);
+            $bytes += (int) parent::write($package, $length);
         }
 
         return $bytes;
@@ -50,7 +50,7 @@ 
         $id = substr(md5(uniqid('', true), true), 0, 8);
 
         foreach ($chunks as $n => &$chunk) {
-            $chunk = self::CHUNK_MAGIC_ID . $id . pack('CC', $n, $count) . $chunk;
+            $chunk = self::CHUNK_MAGIC_ID.$id.pack('CC', $n, $count).$chunk;
         }
 
         return $chunks;

src/Socket.php

Spacing +2 added lines, -2 removed lines

@@ -26,8 +26,8 @@
      */
     public function connect(string $address, int $port = 0, array $options = []): TransportInterface
     {
-        $timeout = (float)($options['timeout'] ??(float) ini_get('default_socket_timeout'));
-        $url = $this->socketPrefix . $address;
+        $timeout = (float) ($options['timeout'] ??(float) ini_get('default_socket_timeout'));
+        $url = $this->socketPrefix.$address;
         $this->socket = @fsockopen($url, $port, $this->errorNumber, $this->errorMessage, $timeout);
 
         return $this;

src/TcpSocket.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
         parent::connect($address, $port, $options);
 
         if ($this->socket === false) {
-            throw new RuntimeException('can`t open socket - ' . $this->errorNumber . ': ' . $this->errorMessage);
+            throw new RuntimeException('can`t open socket - '.$this->errorNumber.': '.$this->errorMessage);
         }
 
         return $this;
@@ -22,6 +22,6 @@ 
 
     public function write(string $buffer, int $length = null): int
     {
-        return parent::write($buffer . "\0", $length);
+        return parent::write($buffer."\0", $length);
     }
 }