edefimov / async-sockets

src/RequestExecutor/Pipeline/DisconnectStage.php

Spacing +1 added lines, -1 removed lines

@@ -97,7 +97,7 @@
         $descriptor->setMetadata(RequestExecutorInterface::META_REQUEST_COMPLETE, true);
         try {
             $socket->close();
-            if ($meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null) {
+            if ($meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null) {
                 $this->callSocketSubscribers(
                     $descriptor,
                     $this->createEvent($descriptor, EventType::DISCONNECTED)

src/RequestExecutor/Pipeline/AbstractTimeAwareStage.php

Spacing +3 added lines, -5 removed lines

@@ -41,8 +41,7 @@ 
     {
         $meta = $operation->getMetadata();
         return !$this->hasConnected($operation) ?
-            $meta[ RequestExecutorInterface::META_CONNECTION_TIMEOUT ] :
-            $meta[ RequestExecutorInterface::META_IO_TIMEOUT ];
+            $meta[RequestExecutorInterface::META_CONNECTION_TIMEOUT] : $meta[RequestExecutorInterface::META_IO_TIMEOUT];
     }
 
     /**
@@ -56,8 +55,7 @@ 
     {
         $meta = $operation->getMetadata();
         return !$this->hasConnected($operation) ?
-            $meta[ RequestExecutorInterface::META_CONNECTION_START_TIME ] :
-            $meta[ RequestExecutorInterface::META_LAST_IO_START_TIME ];
+            $meta[RequestExecutorInterface::META_CONNECTION_START_TIME] : $meta[RequestExecutorInterface::META_LAST_IO_START_TIME];
     }
 
     /**
@@ -74,7 +72,7 @@ 
         $meta  = $requestDescriptor->getMetadata();
         $table = [
             RequestExecutorInterface::META_CONNECTION_START_TIME =>
-                $meta[ RequestExecutorInterface::META_CONNECTION_START_TIME ] === null,
+                $meta[RequestExecutorInterface::META_CONNECTION_START_TIME] === null,
 
             RequestExecutorInterface::META_CONNECTION_FINISH_TIME =>
                 $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] === null,

src/RequestExecutor/Pipeline/WriteIoHandler.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
                 $operation,
                 $executor,
                 $socket,
-                $meta[ RequestExecutorInterface::META_USER_CONTEXT ]
+                $meta[RequestExecutorInterface::META_USER_CONTEXT]
             );
             $eventHandler->invokeEvent($event, $executor, $descriptor->getSocket(), $executionContext);
             $nextOperation = $event->getNextOperation();

src/RequestExecutor/LibEventRequestExecutor.php

Spacing +2 added lines, -2 removed lines

@@ -106,7 +106,7 @@ 
         parent::initializeRequest($eventCaller, $executionContext);
         $this->base = new LeBase();
 
-        $this->connectStage    = $this->stageFactory->createConnectStage(
+        $this->connectStage = $this->stageFactory->createConnectStage(
             $this,
             $executionContext,
             $eventCaller,
@@ -186,7 +186,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/Socket/Io/AbstractIo.php

Spacing +1 added lines, -1 removed lines

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

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

src/Operation/ReadWriteOperation.php

Spacing +2 added lines, -4 removed lines

@@ -105,8 +105,7 @@ 
     public function getReadOperation()
     {
         return !empty($this->queue[OperationInterface::OPERATION_READ]) ?
-            reset($this->queue[OperationInterface::OPERATION_READ]) :
-            null;
+            reset($this->queue[OperationInterface::OPERATION_READ]) : null;
     }
 
     /**
@@ -117,8 +116,7 @@ 
     public function getWriteOperation()
     {
         return !empty($this->queue[OperationInterface::OPERATION_WRITE]) ?
-            reset($this->queue[OperationInterface::OPERATION_WRITE]) :
-            null;
+            reset($this->queue[OperationInterface::OPERATION_WRITE]) : null;
     }
 
     /**