edefimov / async-sockets

src/Operation/WriteOperation.php

Doc Comments +2 added lines, -2 removed lines

@@ -71,7 +71,7 @@ 
     /**
      * Return Data
      *
-     * @return string|array|\Traversable
+     * @return string|null
      */
     public function getData()
     {
@@ -81,7 +81,7 @@ 
     /**
      * Sets Data
      *
-     * @param string|array|\Traversable $data Data to send
+     * @param \AsyncSockets\RequestExecutor\Pipeline\PushbackIterator $data Data to send
      *
      * @return void
      */

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
      */
     public function __construct($data = null, $isOutOfBand = false)
     {
-        $this->data         = $data !== null ? $data : null;
+        $this->data = $data !== null ? $data : null;
         $this->isOutOfBand = $isOutOfBand;
     }
 

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