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

src/Socket/Io/StreamedClientIo.php

Spacing +2 added lines, -3 removed lines

@@ -64,9 +64,8 @@
     private function resolveReadAttempts(array $context, $currentAttempts)
     {
         return ($context['countCycles'] === 1 && $context['dataBeforeIo'] === false) ||
-               ($context['countCycles'] > 1   && $context['isStreamDataEmpty']) ?
-            $currentAttempts - 1 :
-            self::READ_ATTEMPTS;
+               ($context['countCycles'] > 1 && $context['isStreamDataEmpty']) ?
+            $currentAttempts - 1 : self::READ_ATTEMPTS;
 
     }
 

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

Spacing +1 added lines, -1 removed lines

@@ -184,7 +184,7 @@
             'unix' => self::SOCKET_TYPE_UNIX,
         ];
 
-        $regexp = '#^('. implode('|', array_keys($map)) . ')_socket$#';
+        $regexp = '#^(' . implode('|', array_keys($map)) . ')_socket$#';
         foreach ($parts as $part) {
             if (preg_match($regexp, $part, $pockets)) {
                 return $map[$pockets[1]];

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

Spacing +6 added lines, -6 removed lines

@@ -50,9 +50,9 @@ 
     {
         $options = $options + $this->getDefaultOptions();
 
-        $this->connectTimeout   = (double) $options[ 'connectTimeout' ];
-        $this->ioTimeout        = (double) $options[ 'ioTimeout' ];
-        $this->preferredEngines = (array) $options[ 'preferredEngines' ];
+        $this->connectTimeout   = (double) $options['connectTimeout'];
+        $this->ioTimeout        = (double) $options['ioTimeout'];
+        $this->preferredEngines = (array) $options['preferredEngines'];
     }
 
     /**
@@ -95,9 +95,9 @@ 
         $result        = [];
         $socketTimeout = (double) ini_get('default_socket_timeout');
 
-        $result[ 'connectTimeout' ]   = $socketTimeout;
-        $result[ 'ioTimeout' ]        = $socketTimeout;
-        $result[ 'preferredEngines' ] = [ 'libevent', 'native' ];
+        $result['connectTimeout']   = $socketTimeout;
+        $result['ioTimeout']        = $socketTimeout;
+        $result['preferredEngines'] = ['libevent', 'native'];
 
         return $result;
     }

src/RequestExecutor/Metadata/SocketBag.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
     public function __construct(RequestExecutorInterface $executor, $connectTimeout, $ioTimeout)
     {
         $this->executor       = $executor;
-        $this->items          = [ ];
+        $this->items          = [];
         $this->connectTimeout = $connectTimeout;
         $this->ioTimeout      = $ioTimeout;
     }
@@ -156,7 +156,7 @@ 
         ];
 
         if (!is_array($key)) {
-            $key = [ $key => $value ];
+            $key = [$key => $value];
         }
 
         $key = array_intersect_key($key, $writableKeys);

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