Add method chaining to examples

Author: Marc Aschmann

lib/PhpFlo/Component/Counter.php

@@ -49,8 +49,11 @@ public function appendCount($data)
 
     public function sendCount()
     {
-        $this->outPorts()->count->send($this->count);
-        $this->outPorts()->count->disconnect();
+        $this->outPorts()
+            ->count
+            ->send($this->count)
+            ->disconnect();
+
         $this->count = null;
     }
 }

lib/PhpFlo/Component/Queue.php

@@ -42,11 +42,13 @@ public function __construct()
         $this->size = 100;
         $this->messages = [];
 
-        $this->inPorts()->add('in', ['datatype' => 'all']);
-        $this->inPorts()->add('size', ['datatype' => 'all']);
+        $this->inPorts()
+            ->add('in', ['datatype' => 'all'])
+            ->add('size', ['datatype' => 'all']);
 
-        $this->outPorts()->add('error', ['datatype' => 'all']);
-        $this->outPorts()->add('messages', ['datatype' => 'all']);
+        $this->outPorts()
+            ->add('error', ['datatype' => 'all'])
+            ->add('messages', ['datatype' => 'all']);
 
         $this->inPorts()->in->on('data', [$this, 'onAppendQueue']);
         $this->inPorts()->in->on('detach', [$this, 'onStreamEnded']);
@@ -96,8 +98,10 @@ private function sendQueue()
 
     private function flushQueue()
     {
-        $this->outPorts()->messages->send($this->messages);
-        $this->outPorts()->messages->disconnect();
+        $this->outPorts()
+            ->messages
+            ->send($this->messages)
+            ->disconnect();
 
         $this->messages = [];
     }

lib/PhpFlo/Component/ReadFile.php

@@ -23,8 +23,9 @@ class ReadFile extends Component
     public function __construct()
     {
         $this->inPorts()->add('source', ['datatype' => 'string']);
-        $this->outPorts()->add('out', ['datatype' => 'string']);
-        $this->outPorts()->add('error', []); // use defaults, datatype = all
+        $this->outPorts()
+            ->add('out', ['datatype' => 'string'])
+            ->add('error', []); // use defaults, datatype = all
 
         $this->inPorts()->source->on('data', [$this, 'readFile']);
     }
@@ -40,7 +41,9 @@ public function readFile($data)
             return;
         }
 
-        $this->outPorts()->out->send(file_get_contents($data));
-        $this->outPorts()->out->disconnect();
+        $this->outPorts()
+            ->out
+            ->send(file_get_contents($data))
+            ->disconnect();
     }
 }

lib/PhpFlo/Component/SplitStr.php

@@ -32,8 +32,9 @@ class SplitStr extends Component
 
     public function __construct()
     {
-        $this->inPorts()->add('in', ['datatype' => 'string']);
-        $this->inPorts()->add('delimiter', ['datatype' => 'string']);
+        $this->inPorts()
+            ->add('in', ['datatype' => 'string'])
+            ->add('delimiter', ['datatype' => 'string']);
         $this->outPorts()->add('out', ['datatype' => 'string']);
 
         $this->inPorts()->delimiter->on('data', [$this, 'setDelimiter']);