tidal / PEIP

src/Event/Event.php

Spacing +9 added lines, -9 removed lines

@@ -51,7 +51,7 @@ 
      * @param string $name the name of the event

      * @param array|ArrayAccess $headers the headers for the event 

      */

-    public function __construct($subject, $name, $parameters = array(), $type = false){

+    public function __construct($subject, $name, $parameters = array(), $type = false) {

         parent::__construct($subject, Test::ensureArrayAccess($parameters));

         $this->name = $name;

         $this->type = $type ? $type : get_class($this);

@@ -63,7 +63,7 @@ 
      * @access public

      * @return string the name of the event

      */

-    public function getName(){

+    public function getName() {

         return $this->name;

     }

 

@@ -74,7 +74,7 @@ 
      * @access public

      * @return string the type of the event

      */

-    public function getType(){

+    public function getType() {

         return $this->name;

     }

   

@@ -84,7 +84,7 @@ 
      * @access public

      * @param mixed $value the return-value to set 

      */

-    public function setReturnValue($value){

+    public function setReturnValue($value) {

         $this->value = $value;

     }

   

@@ -94,7 +94,7 @@ 
      * @access public

      * @return mixed the return-value to set

      */

-    public function getReturnValue(){

+    public function getReturnValue() {

         return $this->value;

     }

   

@@ -104,8 +104,8 @@ 
      * @access public

      * @param boolean $processed 

      */

-    public function setProcessed($processed){

-        $this->processed = (boolean) $processed;

+    public function setProcessed($processed) {

+        $this->processed = (boolean)$processed;

     }

 

     /**

@@ -114,7 +114,7 @@ 
      * @access public

      * @return boolean wether the event is processed 

      */

-    public function isProcessed(){

+    public function isProcessed() {

         return $this->processed;

     }

 

@@ -124,7 +124,7 @@ 
      * @access public

      * @return mixed the subject/content

      */

-    public function getSubject(){

+    public function getSubject() {

         return $this->getContent();

     }

 }

src/ABS/Dispatcher/Dispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -33,16 +33,16 @@ 
      * @param mixed $subject subject to notify the listeners of 

      * @return void

      */ 

-    protected static function doNotify(array $listeners, $subject){

-        foreach($listeners as $listener){

+    protected static function doNotify(array $listeners, $subject) {

+        foreach ($listeners as $listener) {

             self::doNotifyOne($listener, $subject);

         }   

     }  

 

-    protected static function doNotifyOne($listener, $subject){

-        if(is_callable($listener)){

+    protected static function doNotifyOne($listener, $subject) {

+        if (is_callable($listener)) {

             $res = call_user_func($listener, $subject);

-        }else{

+        }else {

             $res = $listener->handle($subject);

         }

         return $res;

@@ -58,9 +58,9 @@ 
      * @param mixed $subject subject to notify the listeners of 

      * @return \PEIP\INF\Handler\Handler listener that returned a boolean true value

      */     

-    protected static function doNotifyUntil(array $listeners, $subject){

-        foreach ($listeners as $listener){

-          if (self::doNotifyOne($listener, $subject)){

+    protected static function doNotifyUntil(array $listeners, $subject) {

+        foreach ($listeners as $listener) {

+          if (self::doNotifyOne($listener, $subject)) {

             return $listener;

           }

         }

src/ABS/Dispatcher/MapDispatcher.php

Spacing +17 added lines, -17 removed lines

@@ -44,9 +44,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect

      * @return 

      */

-    public function connect($name, $listener){

+    public function connect($name, $listener) {

         Test::ensureHandler($listener);

-        if (!$this->hasListeners($name)){

+        if (!$this->hasListeners($name)) {

           $this->listeners[$name] = array();

         }

         $this->listeners[$name][] = $listener;

@@ -61,13 +61,13 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect

      * @return 

      */

-    public function disconnect($name, $listener){

-        if (!$this->hasListeners($name)){

+    public function disconnect($name, $listener) {

+        if (!$this->hasListeners($name)) {

             return false;

         }

         $res = false;

-        foreach ($this->listeners[$name] as $i => $callable){

-          if ($listener === $callable){

+        foreach ($this->listeners[$name] as $i => $callable) {

+          if ($listener === $callable) {

             unset($this->listeners[$name][$i]);

             $res = true;

           }

@@ -83,8 +83,8 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect

      * @return

      */

-    public function disconnectAll($name){

-        if (!isset($this->listeners[$name])){

+    public function disconnectAll($name) {

+        if (!isset($this->listeners[$name])) {

             return false;

         }

         $this->listeners[$name] = array();

@@ -98,11 +98,11 @@ 
      * @param string $name name of the event 

      * @return boolean wether any listener is registered for event-name

      */

-    public function hasListeners($name){

-        if (!isset($this->listeners[$name])){

+    public function hasListeners($name) {

+        if (!isset($this->listeners[$name])) {

             return false;

         }

-        return (boolean) count($this->listeners[$name]);

+        return (boolean)count($this->listeners[$name]);

     }

     

     /**

@@ -113,8 +113,8 @@ 
      * @param mixed $subject the subject 

      * @return boolean success

      */

-    public function notify($name, $subject){

-        if($this->hasListeners($name)){

+    public function notify($name, $subject) {

+        if ($this->hasListeners($name)) {

             self::doNotify($this->getListeners($name), $subject);

             return true;

         }

@@ -129,8 +129,8 @@ 
      * @param mixed $subject the subject 

      * @return \PEIP\INF\Handler\Handler listener which returned a boolean true value

      */

-    public function notifyUntil($name, $subject){

-        if($this->hasListeners($name)){

+    public function notifyUntil($name, $subject) {

+        if ($this->hasListeners($name)) {

             return self::doNotifyUntil($this->getListeners($name), $subject);   

         }

         return NULL;

@@ -143,8 +143,8 @@ 
      * @param $name 

      * @return array array of \PEIP\INF\Handler\Handler instances

      */

-    public function getListeners($name){

-        if (!isset($this->listeners[$name])){

+    public function getListeners($name) {

+        if (!isset($this->listeners[$name])) {

         return array();

         }

         return $this->listeners[$name];

src/ABS/Base/Container.php

Spacing +2 added lines, -2 removed lines

@@ -22,7 +22,7 @@ 
 

 

 abstract class Container 

-    implements \PEIP\INF\Base\Container{

+    implements \PEIP\INF\Base\Container {

 

     protected $content;

        

@@ -33,7 +33,7 @@ 
      * @access public

      * @return 

      */

-    public function getContent(){

+    public function getContent() {

         return $this->content;

     }

     

src/ABS/Base/Connectable.php

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 

  */

 

-abstract class Connectable  implements \PEIP\INF\Event\Connectable{

+abstract class Connectable  implements \PEIP\INF\Event\Connectable {

 

     const

         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',

@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

-    public function connect($name, $listener){

+    public function connect($name, $listener) {

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->connect($name, $this, $listener);

         $this->doFireEvent(

@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

-    public function disconnect($name, $listener){

+    public function disconnect($name, $listener) {

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->disconnect($name, $this, $listener);

         $this->doFireEvent(

@@ -82,7 +82,7 @@ 
      * @param $name

      * @return

      */

-    public function hasListeners($name){

+    public function hasListeners($name) {

         return $this->getEventDispatcher()->hasListeners($name, $this);

     }

 

@@ -92,7 +92,7 @@ 
      * @param $name

      * @return

      */

-    public function getListeners($name){

+    public function getListeners($name) {

         return $this->getEventDispatcher()->getListeners($name, $this);

     }

 

@@ -102,7 +102,7 @@ 
      * @param $callable

      * @return

      */

-    public function disconnectAll($name){

+    public function disconnectAll($name) {

         $this->getEventDispatcher()->disconnectAll($name, $this);

     }

 

@@ -112,11 +112,11 @@ 
      * @param $transferListners

      * @return

      */

-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){

-        if($transferListners){

-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){

-                if($this->getEventDispatcher()->hasListeners($name, $this)){

-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){

+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {

+        if ($transferListners) {

+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {

+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {

+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {

                         $dispatcher->connect($name, $this, $listener);

                     }

                 }

@@ -131,11 +131,11 @@ 
      * @access public

      * @return

      */

-    public function getEventDispatcher(){

+    public function getEventDispatcher() {

         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();

     }

 

-    protected static function getSharedEventDispatcher(){

+    protected static function getSharedEventDispatcher() {

         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;

         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;

     }

@@ -148,12 +148,12 @@ 
      * @param $eventClass

      * @return

      */

-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){

+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {

         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;

         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);

     }

 

-    protected static function getDefaultEventClass(){

+    protected static function getDefaultEventClass() {

         return self::DEFAULT_EVENT_CLASS;

     }

 }

src/ABS/Base/MutableContainer.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      * @access public

      * @return mixed content

      */

-    public function getContent(){

+    public function getContent() {

         return parent::getContent();

     } 

 }
\ No newline at end of file

src/ABS/Pipe/EventPipe.php

Spacing +5 added lines, -5 removed lines

@@ -38,8 +38,8 @@ 
      * @param string $eventName name of the event to listen to 

      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 

      */

-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){

-        if(!$connectable->hasListener($eventName, $this)){

+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {

+        if (!$connectable->hasListener($eventName, $this)) {

             $connectable->connect($eventName, $this);

             $this->connections[spl_object_hash($connectable)] = $connectable;   

         }   

@@ -52,8 +52,8 @@ 
      * @param string $eventName name of the event to unlisten 

      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 

      */

-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){

-        if(!$connectable->hasListener($eventName, $this)){

+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {

+        if (!$connectable->hasListener($eventName, $this)) {

             $connectable->disconnect($eventName, $this);

             unset($this->connections[spl_object_hash($connectable)]);   

         }   

@@ -65,7 +65,7 @@ 
      * @access public

      * @return array array of \PEIP\INF\Event\Connectable instances

      */

-    public function doGetConnected(){

+    public function doGetConnected() {

         return array_values($this->connections);

     }

     

src/ABS/Transformer/Transformer.php

Spacing +4 added lines, -4 removed lines

@@ -37,9 +37,9 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 

      * @return 

      */

-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){

+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {

         $this->setInputChannel($inputChannel);

-        if(is_object($outputChannel)){

+        if (is_object($outputChannel)) {

             $this->setOutputChannel($outputChannel);    

         }   

     }           

@@ -51,7 +51,7 @@ 
      * @param \PEIP\INF\Message\Message $message message to transform content 

      * @return 

      */

-    public function doReply(\PEIP\INF\Message\Message $message){     

+    public function doReply(\PEIP\INF\Message\Message $message) {     

         $this->replyMessage($this->transform($message));

     }

   

@@ -62,7 +62,7 @@ 
      * @param \PEIP\INF\Message\Message $message 

      * @return mixed result of transforming the message 

      */

-    public function transform(\PEIP\INF\Message\Message $message){

+    public function transform(\PEIP\INF\Message\Message $message) {

         return $this->doTransform($message);

     }

 

src/ABS/Transformer/ContentTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param \PEIP\INF\Message\Message $message 

      * @return mixed result of transforming the message payload/content 

      */

-    protected function doTransform(\PEIP\INF\Message\Message $message){

+    protected function doTransform(\PEIP\INF\Message\Message $message) {

         return $this->transformContent($message->getContent());    

     }