edefimov / async-sockets

src/Socket/PersistentClientSocket.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
     protected function createSocketResource($address, $context)
     {
         $resource = stream_socket_client(
-            $address . ($this->persistentKey ? '/' . $this->persistentKey : ''),
+            $address.($this->persistentKey ? '/'.$this->persistentKey : ''),
             $errno,
             $errstr,
             null,

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]];

src/RequestExecutor/LibEvent/LeBase.php

Spacing +3 added lines, -3 removed lines

@@ -211,9 +211,9 @@
     private function onEvent(LeEvent $event, $eventFlags)
     {
         $map = [
-            LeCallbackInterface::EVENT_READ    => [ EV_READ, RequestDescriptor::RDS_READ ],
-            LeCallbackInterface::EVENT_WRITE   => [ EV_WRITE, RequestDescriptor::RDS_WRITE ],
-            LeCallbackInterface::EVENT_TIMEOUT => [ EV_TIMEOUT, 0 ],
+            LeCallbackInterface::EVENT_READ    => [EV_READ, RequestDescriptor::RDS_READ],
+            LeCallbackInterface::EVENT_WRITE   => [EV_WRITE, RequestDescriptor::RDS_WRITE],
+            LeCallbackInterface::EVENT_TIMEOUT => [EV_TIMEOUT, 0],
         ];
 
         $descriptor = $event->getRequestDescriptor();

src/RequestExecutor/Pipeline/AbstractOobHandler.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         return new Event(
             $this->executor,
             $operation->getSocket(),
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $eventName
         );
     }

src/RequestExecutor/LibEventRequestExecutor.php

Spacing +2 added lines, -2 removed lines

@@ -117,7 +117,7 @@ 
     protected function terminateRequest()
     {
         parent::terminateRequest();
-        $this->base        = null;
+        $this->base = null;
 
         $this->connectStage    = null;
         $this->ioStage         = null;
@@ -181,7 +181,7 @@ 
             case LeCallbackInterface::EVENT_READ:
                 // fall down
             case LeCallbackInterface::EVENT_WRITE:
-                $result       = $this->ioStage->processStage([ $requestDescriptor ]);
+                $result       = $this->ioStage->processStage([$requestDescriptor]);
                 $doResetEvent = empty($result);
 
                 break;