edefimov / async-sockets

src/Socket/AsyncSelector.php

Spacing +3 added lines, -4 removed lines

@@ -239,8 +239,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);
@@ -281,8 +281,7 @@ 
      */
     private function calculateAttemptsCount($seconds, $usec)
     {
-        return $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) :
-            self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
+        return $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) : self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
     }
 
     /**

src/RequestExecutor/Pipeline/GuardianStage.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         return new Event(
             $this->executor,
             $operation->getSocket(),
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $eventName
         );
     }

src/RequestExecutor/Pipeline/ConnectStageReturningAllActiveSockets.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
         $result = [];
         foreach ($operations as $key => $item) {
             $meta     = $item->getMetadata();
-            $isActive = !$meta[ RequestExecutorInterface::META_REQUEST_COMPLETE ] &&
+            $isActive = !$meta[RequestExecutorInterface::META_REQUEST_COMPLETE] &&
                         $item->isRunning() &&
                         !$item->isPostponed();