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/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/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
         );
     }