edefimov / async-sockets

src/RequestExecutor/Pipeline/TimeoutStage.php

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/DisconnectStage.php

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/GuardianStage.php

Indentation +2 added lines, -2 removed lines

@@ -123,9 +123,9 @@
         $operation = $descriptor->getOperation();
         return ($operation instanceof NullOperation) ||
                (
-                   $operation instanceof ReadOperation &&
+                    $operation instanceof ReadOperation &&
                    $operation->getFramePicker() instanceof EmptyFramePicker
-               );
+                );
     }
 
     /**

src/Frame/MarkerFramePicker.php

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/RequestExecutor/Pipeline/SelectStage.php

Doc Comments +1 added lines, -1 removed lines

@@ -179,7 +179,7 @@
      * @param RequestDescriptor $operation Operation object
      * @param double            $microTime Current time with microseconds
      *
-     * @return double|null
+     * @return double
      */
     private function getSingleSocketTimeout(RequestDescriptor $operation, $microTime)
     {