edefimov / async-sockets

src/RequestExecutor/Pipeline/ConnectStage.php

Spacing +3 added lines, -3 removed lines

@@ -59,7 +59,7 @@ 
             } elseif ($decision === LimitationSolverInterface::DECISION_SKIP_CURRENT) {
                 continue;
             } elseif ($decision !== LimitationSolverInterface::DECISION_OK) {
-                throw new \LogicException('Unknown decision ' . $decision . ' received.');
+                throw new \LogicException('Unknown decision '.$decision.' received.');
             }
 
             if ($this->connectSocket($descriptor)) {
@@ -125,8 +125,8 @@ 
             if (!$socket->isConnected()) {
                 $meta = $descriptor->getMetadata();
                 $socket->open(
-                    $meta[ RequestExecutorInterface::META_ADDRESS ],
-                    $meta[ RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
+                    $meta[RequestExecutorInterface::META_ADDRESS],
+                    $meta[RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
                 );
             } else {
                 $this->setSocketOperationTime($descriptor, RequestExecutorInterface::META_CONNECTION_FINISH_TIME);

src/RequestExecutor/Pipeline/TimeoutStage.php

Spacing +2 added lines, -3 removed lines

@@ -23,7 +23,7 @@ 
     public function processStage(array $requestDescriptors)
     {
         /** @var RequestDescriptor[] $requestDescriptors */
-        $result    = [ ];
+        $result    = [];
         $microTime = microtime(true);
         foreach ($requestDescriptors as $key => $descriptor) {
             $isTimeout = $this->isSingleSocketTimeout($descriptor, $microTime) &&
@@ -52,8 +52,7 @@ 
             $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null &&
             !$descriptor->getSocket()->isServer() ?
-                TimeoutEvent::DURING_IO :
-                TimeoutEvent::DURING_CONNECTION
+                TimeoutEvent::DURING_IO : TimeoutEvent::DURING_CONNECTION
         );
         try {
             $this->callSocketSubscribers($descriptor, $event);

src/RequestExecutor/Pipeline/ConnectStageReturningAllActiveSockets.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
     private function isDescriptorActive(RequestDescriptor $descriptor)
     {
         $meta = $descriptor->getMetadata();
-        return !$meta[ RequestExecutorInterface::META_REQUEST_COMPLETE ] &&
+        return !$meta[RequestExecutorInterface::META_REQUEST_COMPLETE] &&
                     $descriptor->isRunning() &&
                     !$descriptor->isForgotten();
     }

src/Socket/ServerSocket.php

Spacing +2 added lines, -3 removed lines

@@ -85,9 +85,8 @@
             'udg' => 1,
         ];
 
-        return isset($connectionLessMap[ $scheme ]) ?
-            STREAM_SERVER_BIND :
-            STREAM_SERVER_BIND | STREAM_SERVER_LISTEN;
+        return isset($connectionLessMap[$scheme]) ?
+            STREAM_SERVER_BIND : STREAM_SERVER_BIND | STREAM_SERVER_LISTEN;
     }
 
     /**