edefimov / async-sockets

src/Operation/WriteOperation.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
      */
     public function __construct($data = null, $isOutOfBand = false)
     {
-        $this->data         = $data !== null ? (string) $data : null;
+        $this->data = $data !== null ? (string) $data : null;
         $this->isOutOfBand = $isOutOfBand;
     }
 

src/Socket/Io/AbstractIo.php

Spacing +2 added lines, -2 removed lines

@@ -60,8 +60,8 @@
             $lastError = $includeLastError ? error_get_last() : null;
             if ($lastError) {
                 $phpMessage = explode(':', $lastError['message'], 2);
-                $phpMessage = trim(trim(end($phpMessage)), '.') . '.';
-                $message   .= ' ' . $phpMessage;
+                $phpMessage = trim(trim(end($phpMessage)), '.').'.';
+                $message   .= ' '.$phpMessage;
             }
             throw new NetworkSocketException($this->socket, $message);
         }

src/Socket/Io/DatagramClientIo.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
         parent::__construct($socket, 0);
         if ($remoteAddress) {
             $components = parse_url($remoteAddress);
-            $this->remoteAddress = $components['host'] . ':' . $components['port'];
+            $this->remoteAddress = $components['host'].':'.$components['port'];
         }
     }
 

src/Socket/Io/StreamedClientIo.php

Spacing +3 added lines, -5 removed lines

@@ -71,9 +71,8 @@ 
     private function resolveReadAttempts(array $context, $currentAttempts)
     {
         return ($context['countCycles'] === 1 && empty($context['dataBeforeIo'])) ||
-               ($context['countCycles'] > 1   && $context['isStreamDataEmpty']) ?
-            $currentAttempts - 1 :
-            self::READ_ATTEMPTS;
+               ($context['countCycles'] > 1 && $context['isStreamDataEmpty']) ?
+            $currentAttempts - 1 : self::READ_ATTEMPTS;
 
     }
 
@@ -85,8 +84,7 @@ 
         $this->throwNetworkSocketExceptionIf($test !== 0, 'Failed to send data.', true);
 
         $written = $isOutOfBand ?
-            $this->writeOobData($resource, $data) :
-            fwrite($resource, $data, strlen($data));
+            $this->writeOobData($resource, $data) : fwrite($resource, $data, strlen($data));
 
         $this->throwNetworkSocketExceptionIf($written === false, 'Failed to send data.', true);
 

src/Socket/AbstractSocket.php

Spacing +1 added lines, -1 removed lines

@@ -182,7 +182,7 @@
             'unix' => self::SOCKET_TYPE_UNIX,
         ];
 
-        $regexp = '#^('. implode('|', array_keys($map)) . ')_socket$#';
+        $regexp = '#^('.implode('|', array_keys($map)).')_socket$#';
         foreach ($parts as $part) {
             if (preg_match($regexp, $part, $pockets)) {
                 return $map[$pockets[1]];