edefimov / async-sockets

src/RequestExecutor/LibEventRequestExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -104,7 +104,7 @@ 
     protected function initializeRequest(EventCaller $eventCaller)
     {
         parent::initializeRequest($eventCaller);
-        $this->base        = new LeBase();
+        $this->base = new LeBase();
 
         $this->connectStage    = $this->stageFactory->createConnectStage($this, $eventCaller, $this->solver);
         $this->ioStage         = $this->stageFactory->createIoStage($this, $eventCaller);
@@ -117,7 +117,7 @@ 
     protected function terminateRequest()
     {
         parent::terminateRequest();
-        $this->base        = null;
+        $this->base = null;
 
         $this->connectStage    = null;
         $this->ioStage         = null;
@@ -168,7 +168,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/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]);
             }
         }