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;

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/TimeoutStage.php

Indentation +10 added lines, -10 removed lines

@@ -1,12 +1,12 @@ 
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\RequestExecutor\Pipeline;
 
 use AsyncSockets\Event\TimeoutEvent;
@@ -114,10 +114,10 @@ 
 
         return ($desiredTimeout !== RequestExecutorInterface::WAIT_FOREVER) &&
                (
-                   ($hasConnected && $lastOperationTime !== null) ||
+                    ($hasConnected && $lastOperationTime !== null) ||
                    !$hasConnected
-               ) &&
+                ) &&
                ($microTime - $lastOperationTime >= $desiredTimeout)
-               ;
+                ;
     }
 }

src/RequestExecutor/Pipeline/GuardianStage.php

Indentation +9 added lines, -9 removed lines

@@ -1,12 +1,12 @@ 
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\RequestExecutor\Pipeline;
 
 use AsyncSockets\Event\DataAlertEvent;
@@ -119,9 +119,9 @@ 
         $operation = $descriptor->getOperation();
         return ($operation instanceof NullOperation) ||
                (
-                   $operation instanceof ReadOperation &&
+                    $operation instanceof ReadOperation &&
                    $operation->getFramePicker() instanceof EmptyFramePicker
-               );
+                );
     }
 
     /**

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

Indentation +13 added lines, -13 removed lines

@@ -1,12 +1,12 @@ 
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\RequestExecutor\Pipeline;
 
 use AsyncSockets\Event\EventType;
@@ -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/Socket/UdpClientSocket.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/Socket/AsyncSelector.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/Socket/SelectContext.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/Socket/ServerSocket.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/Socket/AsyncSocketFactory.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;