edefimov / async-sockets

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