edefimov / async-sockets

src/Socket/AsyncSelector.php

Spacing +3 added lines, -4 removed lines

@@ -108,8 +108,7 @@ 
      */
     private function calculateAttemptsCount($seconds, $usec)
     {
-        $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) :
-            self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
+        $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) : self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
         if ($result < self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT) {
             $result = self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
         }
@@ -328,8 +327,8 @@ 
      */
     public function removeAllSocketOperations(StreamResourceInterface $streamResource)
     {
-        $opList = [ OperationInterface::OPERATION_READ,
-                    OperationInterface::OPERATION_WRITE  ];
+        $opList = [OperationInterface::OPERATION_READ,
+                    OperationInterface::OPERATION_WRITE];
 
         foreach ($opList as $op) {
             $this->removeSocketOperation($streamResource, $op);

src/Socket/Io/StreamedClientIo.php

Spacing +7 added lines, -9 removed lines

@@ -52,18 +52,17 @@ 
         if ($test !== 0) {
             throw new SendDataException(
                 $this->socket,
-                trim('Failed to send data. ' . $this->getLastPhpErrorMessage())
+                trim('Failed to send data. '.$this->getLastPhpErrorMessage())
             );
         }
 
         $written = $isOutOfBand ?
-            $this->writeOobData($resource, $data) :
-            fwrite($resource, $data, strlen($data));
+            $this->writeOobData($resource, $data) : fwrite($resource, $data, strlen($data));
 
         if ($written === false) {
             throw new SendDataException(
                 $this->socket,
-                trim('Failed to send data. ' . $this->getLastPhpErrorMessage())
+                trim('Failed to send data. '.$this->getLastPhpErrorMessage())
             );
         }
 
@@ -136,7 +135,7 @@ 
             if ($data === false) {
                 throw new RecvDataException(
                     $this->socket,
-                    trim('Failed to read data. ' . $this->getLastPhpErrorMessage())
+                    trim('Failed to read data. '.$this->getLastPhpErrorMessage())
                 );
             }
 
@@ -190,9 +189,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;
 
     }
 
@@ -213,7 +211,7 @@ 
             if ($written < 0) {
                 throw new SendDataException(
                     $this->socket,
-                    trim('Failed to send data. ' . $this->getLastPhpErrorMessage())
+                    trim('Failed to send data. '.$this->getLastPhpErrorMessage())
                 );
             }
 

src/Socket/Io/AbstractIo.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
         $lastError = error_get_last();
         if ($lastError) {
             $phpMessage = explode(':', $lastError['message'], 2);
-            $phpMessage = trim(trim(end($phpMessage)), '.') . '.';
+            $phpMessage = trim(trim(end($phpMessage)), '.').'.';
             return $phpMessage;
         }
 

src/Socket/AbstractSocket.php

Spacing +2 added lines, -3 removed lines

@@ -174,8 +174,7 @@ 
                 '[#%s, %s]',
                 preg_replace('/Resource id #(\d+)/i', '$1', (string) $this->resource),
                 $this->remoteAddress
-            ) :
-            '[closed socket]';
+            ) : '[closed socket]';
     }
 
     /**
@@ -218,7 +217,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/Frame/MarkerFramePicker.php

Doc Comments +1 added lines, -1 removed lines

@@ -121,7 +121,7 @@
      * @param string $needle What to find
      * @param int    $offset Start offset in $haystack
      *
-     * @return bool|int
+     * @return string
      */
     protected function findMarker($haystack, $needle, $offset = 0)
     {

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;

src/RequestExecutor/Metadata/SpeedRateCounter.php

Doc Comments +2 added lines, -2 removed lines

@@ -140,7 +140,7 @@ 
     /**
      * Return average speed for measurements
      *
-     * @return double|null
+     * @return integer
      */
     private function getAverageSpeed()
     {
@@ -152,7 +152,7 @@ 
     /**
      * Return current speed in bytes per seconds
      *
-     * @return float
+     * @return integer
      */
     public function getCurrentSpeed()
     {