edefimov / async-sockets

src/Socket/AsyncSocketFactory.php

Spacing +5 added lines, -7 removed lines

@@ -75,15 +75,13 @@
     {
         switch ($type) {
             case self::SOCKET_CLIENT:
-                $isPersistent  = isset($options[ self::SOCKET_OPTION_IS_PERSISTENT ]) &&
-                                 $options[ self::SOCKET_OPTION_IS_PERSISTENT ];
-                $persistentKey = isset($options[ self::SOCKET_OPTION_PERSISTENT_KEY ]) ?
-                    $options[ self::SOCKET_OPTION_PERSISTENT_KEY ] :
-                    null;
+                $isPersistent  = isset($options[self::SOCKET_OPTION_IS_PERSISTENT]) &&
+                                 $options[self::SOCKET_OPTION_IS_PERSISTENT];
+                $persistentKey = isset($options[self::SOCKET_OPTION_PERSISTENT_KEY]) ?
+                    $options[self::SOCKET_OPTION_PERSISTENT_KEY] : null;
 
                 return $isPersistent ?
-                    new PersistentClientSocket($persistentKey) :
-                    new ClientSocket();
+                    new PersistentClientSocket($persistentKey) : new ClientSocket();
             case self::SOCKET_SERVER:
                 return new ServerSocket();
             default:

src/RequestExecutor/Pipeline/DisconnectStage.php

Indentation +9 added lines, -9 removed lines

@@ -1,12 +1,12 @@ 
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015, 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, 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;
@@ -77,9 +77,9 @@ 
                                 feof($socket->getStreamResource()) !== false ||
                                 !stream_socket_get_name($socket->getStreamResource(), true)
                             )
-                         ) || (
+                            ) || (
                             !($socket instanceof PersistentClientSocket)
-                         );
+                            );
 
         if (!$isTimeToLeave) {
             return;

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);

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([ $operationMetadata ]);
+                $result       = $this->ioStage->processStage([$operationMetadata]);
                 $doResetEvent = empty($result);
 
                 break;

src/Exception/UnmanagedSocketException.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         return new self(
             $socket,
             sprintf(
-                'System has detected a zombie connection %s and closed it. '.
+                'System has detected a zombie connection %s and closed it. ' .
                 'If you see this message it means that application ' .
                 'has lost control on one of its sockets.',
                 (string) $socket

src/Operation/NullOperation.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 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) 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\Operation;
 
 /**

src/Event/TimeoutEvent.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 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) 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\Operation;
 
 /**

src/Event/DataAlertEvent.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 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) 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\Operation;
 
 /**

src/Frame/EmptyFrame.php

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 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) 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\Operation;
 
 /**