edefimov / async-sockets

src/RequestExecutor/Pipeline/GuardianStage.php

Spacing +2 added lines, -2 removed lines

@@ -115,7 +115,7 @@ 
      */
     private function isZombieCandidate(RequestDescriptor $descriptor)
     {
-        $metadata  = $descriptor->getMetadata();
+        $metadata = $descriptor->getMetadata();
         if ($metadata[RequestExecutorInterface::META_REQUEST_COMPLETE]) {
             return false;
         }
@@ -164,7 +164,7 @@ 
         $event  = new DataAlertEvent(
             $this->executor,
             $socket,
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $attempt,
             $totalAttempts
         );

src/RequestExecutor/Pipeline/ExcludedOperationsStage.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
 
         foreach ($requestDescriptors as $key => $descriptor) {
             if (in_array($descriptor, $currentOperations, true)) {
-                unset($requestDescriptors[ $key]);
+                unset($requestDescriptors[$key]);
             }
         }
 

src/RequestExecutor/Pipeline/IoStage.php

Spacing +2 added lines, -2 removed lines

@@ -86,7 +86,7 @@ 
             }
         }
 
-        throw new \LogicException('There is no handler able to process ' . get_class($operation) . ' operation.');
+        throw new \LogicException('There is no handler able to process '.get_class($operation).' operation.');
     }
 
     /**
@@ -157,7 +157,7 @@ 
     private function setConnectionFinishTime(RequestDescriptor $requestDescriptor)
     {
         $meta         = $requestDescriptor->getMetadata();
-        $wasConnected = $meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null;
+        $wasConnected = $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null;
         $this->setSocketOperationTime($requestDescriptor, RequestExecutorInterface::META_CONNECTION_FINISH_TIME);
         if (!$wasConnected) {
             $event = $this->createEvent($requestDescriptor, EventType::CONNECTED);

src/Exception/UnmanagedSocketException.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
             $socket,
             sprintf(
                 'System has detected a zombie connection %s and closed it. '.
-                'If you see this message it means that application ' .
+                'If you see this message it means that application '.
                 'has lost control on one of its sockets.',
                 (string) $socket
             )

src/Socket/AsyncSocketFactory.php

Spacing +6 added lines, -8 removed lines

@@ -74,19 +74,17 @@
     {
         switch ($type) {
             case self::SOCKET_CLIENT:
-                $isPersistent  = isset($options[ self::SOCKET_OPTION_IS_PERSISTENT ]) &&
-                                 $options[ self::SOCKET_OPTION_IS_PERSISTENT ];
-                $persistentKey = isset($options[ self::SOCKET_OPTION_PERSISTENT_KEY ]) ?
-                    $options[ self::SOCKET_OPTION_PERSISTENT_KEY ] :
-                    null;
+                $isPersistent  = isset($options[self::SOCKET_OPTION_IS_PERSISTENT]) &&
+                                 $options[self::SOCKET_OPTION_IS_PERSISTENT];
+                $persistentKey = isset($options[self::SOCKET_OPTION_PERSISTENT_KEY]) ?
+                    $options[self::SOCKET_OPTION_PERSISTENT_KEY] : null;
 
                 return $isPersistent ?
-                    new PersistentClientSocket($persistentKey) :
-                    new ClientSocket();
+                    new PersistentClientSocket($persistentKey) : new ClientSocket();
             case self::SOCKET_SERVER:
                 return new ServerSocket();
             default:
-                throw new \InvalidArgumentException("Unexpected type {$type} used in " . __FUNCTION__);
+                throw new \InvalidArgumentException("Unexpected type {$type} used in ".__FUNCTION__);
         }
     }
 

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