edefimov / async-sockets

src/Configuration/StreamContext.php

Spacing +5 added lines, -5 removed lines

@@ -56,9 +56,9 @@ 
         }
 
         $map = [
-            'null'     => [ $this, 'createFromNull' ],
-            'resource' => [ $this, 'createFromResource' ],
-            'array'    => [ $this, 'createFromArray' ],
+            'null'     => [$this, 'createFromNull'],
+            'resource' => [$this, 'createFromResource'],
+            'array'    => [$this, 'createFromArray'],
         ];
 
         $type = strtolower(gettype($settings));
@@ -107,8 +107,8 @@ 
     private function createFromArray(array $settings)
     {
         return stream_context_create(
-            isset($settings[ 'options' ]) ? $settings[ 'options' ] : [],
-            isset($settings[ 'params' ]) ? $settings[ 'params' ] : []
+            isset($settings['options']) ? $settings['options'] : [],
+            isset($settings['params']) ? $settings['params'] : []
         );
     }
 }

src/RequestExecutor/Pipeline/PushbackIterator.php

Spacing +1 added lines, -2 removed lines

@@ -163,8 +163,7 @@
         $this->popLastPushedBackItem();
 
         $result .= $this->hasUnreadItem() ?
-            array_shift($this->unreadItems) :
-            (string) $this->nestedIterator->current();
+            array_shift($this->unreadItems) : (string) $this->nestedIterator->current();
 
         while ($this->hasUnreadItem() && strlen($result) < $this->chunkSize) {
             $result .= array_shift($this->unreadItems);

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

src/RequestExecutor/Pipeline/DisconnectStage.php

Spacing +1 added lines, -1 removed lines

@@ -97,7 +97,7 @@
         $descriptor->setMetadata(RequestExecutorInterface::META_REQUEST_COMPLETE, true);
         try {
             $socket->close();
-            if ($meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null) {
+            if ($meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null) {
                 $this->callSocketSubscribers(
                     $descriptor,
                     $this->createEvent($descriptor, EventType::DISCONNECTED)

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, $executor, $descriptor->getSocket(), $executionContext);
             $nextOperation = $event->getNextOperation();

src/RequestExecutor/LibEventRequestExecutor.php

Spacing +2 added lines, -2 removed lines

@@ -106,7 +106,7 @@ 
         parent::initializeRequest($eventCaller, $executionContext);
         $this->base = new LeBase();
 
-        $this->connectStage    = $this->stageFactory->createConnectStage(
+        $this->connectStage = $this->stageFactory->createConnectStage(
             $this,
             $executionContext,
             $eventCaller,
@@ -186,7 +186,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;

src/Socket/Io/AbstractIo.php

Spacing +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
         $lastError = error_get_last();
         if (!empty($lastError)) {
             $phpMessage = explode(':', $lastError['message'], 2);
-            $phpMessage = trim(trim(end($phpMessage)), '.') . '.';
+            $phpMessage = trim(trim(end($phpMessage)), '.').'.';
             return $phpMessage;
         }