edefimov / async-sockets

src/Configuration/Configuration.php

Spacing +12 added lines, -12 removed lines

@@ -95,11 +95,11 @@ 
     {
         $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'];
 
-        $this->streamContext = new StreamContext($options[ 'streamContext' ]);
+        $this->streamContext = new StreamContext($options['streamContext']);
         foreach (['minReceiveSpeed', 'minReceiveSpeedDuration', 'minSendSpeed', 'minSendSpeedDuration'] as $k) {
             $this->{$k} = $options[$k] !== null ? (int) $options[$k] : null;
         }
@@ -195,14 +195,14 @@ 
         $result        = [];
         $socketTimeout = (double) ini_get('default_socket_timeout');
 
-        $result[ 'connectTimeout' ]          = $socketTimeout;
-        $result[ 'ioTimeout' ]               = $socketTimeout;
-        $result[ 'preferredEngines' ]        = [ 'libevent', 'native' ];
-        $result[ 'streamContext' ]           = null;
-        $result[ 'minReceiveSpeed' ]         = null;
-        $result[ 'minReceiveSpeedDuration' ] = null;
-        $result[ 'minSendSpeed' ]            = null;
-        $result[ 'minSendSpeedDuration' ]    = null;
+        $result['connectTimeout']          = $socketTimeout;
+        $result['ioTimeout']               = $socketTimeout;
+        $result['preferredEngines']        = ['libevent', 'native'];
+        $result['streamContext']           = null;
+        $result['minReceiveSpeed']         = null;
+        $result['minReceiveSpeedDuration'] = null;
+        $result['minSendSpeed']            = null;
+        $result['minSendSpeedDuration']    = null;
 
         return $result;
     }

src/Configuration/StreamContext.php

Spacing +2 added lines, -2 removed lines

@@ -59,8 +59,8 @@
             return $settings;
         } elseif (is_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'] : []
             );
         } elseif ($settings === null) {
             return stream_context_get_default();

src/RequestExecutor/Pipeline/ConnectStage.php

Spacing +3 added lines, -3 removed lines

@@ -56,7 +56,7 @@ 
             } elseif ($decision === LimitationSolverInterface::DECISION_SKIP_CURRENT) {
                 continue;
             } elseif ($decision !== LimitationSolverInterface::DECISION_OK) {
-                throw new \LogicException('Unknown decision ' . $decision . ' received.');
+                throw new \LogicException('Unknown decision '.$decision.' received.');
             }
 
             if ($this->connectSocket($descriptor)) {
@@ -117,8 +117,8 @@ 
             $meta = $descriptor->getMetadata();
 
             $socket->open(
-                $meta[ RequestExecutorInterface::META_ADDRESS ],
-                $meta[ RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
+                $meta[RequestExecutorInterface::META_ADDRESS],
+                $meta[RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
             );
 
             $descriptor->setRunning(true);

src/RequestExecutor/Metadata/SocketBag.php

Spacing +1 added lines, -1 removed lines

@@ -178,7 +178,7 @@
         ];
 
         if (!is_array($key)) {
-            $key = [ $key => $value ];
+            $key = [$key => $value];
         }
 
         $key = array_intersect_key($key, $writableKeys);