edefimov / async-sockets

src/Frame/MarkerFramePicker.php

Spacing +1 added lines, -2 removed lines

@@ -126,7 +126,6 @@
     protected function findMarker($haystack, $needle, $offset = 0)
     {
         return $this->isCaseSensitive ?
-            strpos($haystack, $needle, $offset) :
-            stripos($haystack, $needle, $offset);
+            strpos($haystack, $needle, $offset) : stripos($haystack, $needle, $offset);
     }
 }

Doc Comments +1 added lines, -1 removed lines

@@ -121,7 +121,7 @@
      * @param string $needle What to find
      * @param int    $offset Start offset in $haystack
      *
-     * @return bool|int
+     * @return string
      */
     protected function findMarker($haystack, $needle, $offset = 0)
     {

src/Socket/Io/AbstractClientIo.php

Spacing +1 added lines, -2 removed lines

@@ -143,8 +143,7 @@
         $resource = $this->socket->getStreamResource();
         if (!is_resource($resource)) {
             $message = $this->state === self::STATE_CONNECTED ?
-                'Connection was unexpectedly closed.' :
-                'Can not start io operation on uninitialized socket.';
+                'Connection was unexpectedly closed.' : 'Can not start io operation on uninitialized socket.';
             throw new ConnectionException($this->socket, $message);
         }
 

src/Socket/ServerSocket.php

Spacing +2 added lines, -3 removed lines

@@ -68,9 +68,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;
     }
 
     /** {@inheritdoc} */

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);
             $nextOperation = $event->getNextOperation();

src/RequestExecutor/Pipeline/DisconnectStage.php

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
 
         try {
             $socket->close();
-            if ($meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null) {
+            if ($meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null) {
                 $this->callSocketSubscribers($operation, $event);
             }
         } catch (SocketException $e) {

Indentation +6 added lines, -6 removed lines

@@ -136,13 +136,13 @@
     private function isDisconnectRequired(SocketInterface $socket)
     {
         return (
-                   ($socket instanceof PersistentClientSocket) &&
+                    ($socket instanceof PersistentClientSocket) &&
                    (
-                       feof($socket->getStreamResource()) !== false ||
+                        feof($socket->getStreamResource()) !== false ||
                        !stream_socket_get_name($socket->getStreamResource(), true)
-                   )
-               ) || (
-                   !($socket instanceof PersistentClientSocket)
-               );
+                    )
+                ) || (
+                    !($socket instanceof PersistentClientSocket)
+                );
     }
 }

src/RequestExecutor/Pipeline/AbstractStage.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/TimeoutStage.php

Spacing +2 added lines, -3 removed lines

@@ -24,7 +24,7 @@ 
     public function processStage(array $operations)
     {
         /** @var OperationMetadata[] $operations */
-        $result    = [ ];
+        $result    = [];
         $microTime = microtime(true);
         foreach ($operations as $key => $operation) {
             if ($this->isSingleSocketTimeout($operation, $microTime)) {
@@ -53,8 +53,7 @@ 
             $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null &&
             !($descriptor->getSocket() instanceof ServerSocket) ?
-                TimeoutEvent::DURING_IO :
-                TimeoutEvent::DURING_CONNECTION
+                TimeoutEvent::DURING_IO : TimeoutEvent::DURING_CONNECTION
         );
         try {
             $this->callSocketSubscribers($descriptor, $event);

Indentation +3 added lines, -3 removed lines

@@ -114,10 +114,10 @@
 
         return ($desiredTimeout !== RequestExecutorInterface::WAIT_FOREVER) &&
                (
-                   ($hasConnected && $lastOperationTime !== null) ||
+                    ($hasConnected && $lastOperationTime !== null) ||
                    !$hasConnected
-               ) &&
+                ) &&
                ($microTime - $lastOperationTime >= $desiredTimeout)
-               ;
+                ;
     }
 }

src/RequestExecutor/Pipeline/ConnectStageReturningAllActiveSockets.php

Spacing +1 added lines, -1 removed lines

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

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  = $operationMetadata->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,