edefimov / async-sockets

src/RequestExecutor/Pipeline/AbstractOobHandler.php

Spacing +11 added lines, -12 removed lines

@@ -113,7 +113,7 @@ 
         $event  = new ReadEvent(
             $executor,
             $socket,
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $frame,
             true
         );
@@ -140,8 +140,7 @@ 
         if (!$counter) {
             $meta    = $descriptor->getMetadata();
             $counter = new SpeedRateCounter($minRate, $duration);
-            $time    = $meta[RequestExecutorInterface::META_LAST_IO_START_TIME] ?:
-                        $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME];
+            $time    = $meta[RequestExecutorInterface::META_LAST_IO_START_TIME] ?: $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME];
             $counter->advance($time, 0);
             $descriptor->registerCounter($name, $counter);
         }
@@ -204,26 +203,26 @@ 
         $map = [
             RequestDescriptor::COUNTER_RECV_MIN_RATE => [
                 'resetCounter' => RequestDescriptor::COUNTER_SEND_MIN_RATE,
-                'minSpeed'     => $meta[ RequestExecutorInterface::META_MIN_RECEIVE_SPEED ],
-                'duration'     => $meta[ RequestExecutorInterface::META_MIN_RECEIVE_SPEED_DURATION ],
+                'minSpeed'     => $meta[RequestExecutorInterface::META_MIN_RECEIVE_SPEED],
+                'duration'     => $meta[RequestExecutorInterface::META_MIN_RECEIVE_SPEED_DURATION],
                 'bytesCounter' => RequestExecutorInterface::META_BYTES_RECEIVED,
                 'speedCounter' => RequestExecutorInterface::META_RECEIVE_SPEED,
-                'exception'    => [ 'AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataReceiving' ],
+                'exception'    => ['AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataReceiving'],
             ],
             RequestDescriptor::COUNTER_SEND_MIN_RATE => [
                 'resetCounter' => RequestDescriptor::COUNTER_RECV_MIN_RATE,
-                'minSpeed'     => $meta[ RequestExecutorInterface::META_MIN_SEND_SPEED ],
-                'duration'     => $meta[ RequestExecutorInterface::META_MIN_SEND_SPEED_DURATION ],
+                'minSpeed'     => $meta[RequestExecutorInterface::META_MIN_SEND_SPEED],
+                'duration'     => $meta[RequestExecutorInterface::META_MIN_SEND_SPEED_DURATION],
                 'bytesCounter' => RequestExecutorInterface::META_BYTES_SENT,
                 'speedCounter' => RequestExecutorInterface::META_SEND_SPEED,
-                'exception'    => [ 'AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataSending' ],
+                'exception'    => ['AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataSending'],
             ],
         ];
 
-        if (!isset($map[ $name ])) {
-            throw new \LogicException('Can not process counter ' . $name . ' in transfer operation');
+        if (!isset($map[$name])) {
+            throw new \LogicException('Can not process counter '.$name.' in transfer operation');
         }
 
-        return $map[ $name ];
+        return $map[$name];
     }
 }

src/Socket/Io/StreamedClientIo.php

Spacing +5 added lines, -7 removed lines

@@ -52,8 +52,7 @@ 
         $this->verifySendResult('', stream_socket_sendto($resource, ''));
 
         $written = $isOutOfBand ?
-            $this->writeOobData($resource, $data) :
-            fwrite($resource, $data, strlen($data));
+            $this->writeOobData($resource, $data) : fwrite($resource, $data, strlen($data));
 
         $this->verifySendResult($data, $written);
 
@@ -74,7 +73,7 @@ 
         if ($sendResult === false || $sendResult < 0) {
             throw new SendDataException(
                 $this->socket,
-                trim('Failed to send data. ' . $this->getLastPhpErrorMessage())
+                trim('Failed to send data. '.$this->getLastPhpErrorMessage())
             );
         }
 
@@ -148,7 +147,7 @@ 
             if ($data === false) {
                 throw new RecvDataException(
                     $this->socket,
-                    trim('Failed to read data. ' . $this->getLastPhpErrorMessage())
+                    trim('Failed to read data. '.$this->getLastPhpErrorMessage())
                 );
             }
 
@@ -202,9 +201,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;
 
     }