tidal / PEIP

src/Dispatcher/ClassEventDispatcher.php

Braces +2 added lines, -2 removed lines

@@ -70,10 +70,10 @@
                      ),

                      $object

                  );

-            }else{

+            } else{

                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');

             }

-        }else{

+        } else{

             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');

         }

     }       //put your code here

Spacing +9 added lines, -9 removed lines

@@ -26,9 +26,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener event-handler

      * @return boolean

      */

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

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

         $class = is_object($object) ? get_class($object) : (string)$object;

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = \PEIP\Util\ReflectionPool::getInstance($class);

             parent::connect($name, $reflection, $listener);

         }

@@ -36,13 +36,13 @@ 
         return true;

     }

 

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

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

         $class = is_object($object) ? get_class($object) : (string)$object;

         $res = true;

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = \PEIP\Util\ReflectionPool::getInstance($class);

             $r = parent::disconnect($name, $reflection, $listener);

-            if(!$r){

+            if (!$r) {

                 $res = false;

             }

         }

@@ -69,10 +69,10 @@ 
                         ),

                         $object

                     );

-            }else{

+            }else {

                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');

             }

-        }else{

+        }else {

             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');

         }

     }       //put your code here

@@ -89,8 +89,8 @@ 
          * @return

          * @see EventBuilder

          */

-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

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

+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {

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

             return false;

         }

 

examples/Cafe/lib/messaging/DrinkRouter.php

Spacing +2 added lines, -2 removed lines

@@ -6,9 +6,9 @@
 class DrinkRouter 

 	extends Router {

 	

-	protected function selectChannels(Message $message){

+	protected function selectChannels(Message $message) {

 		$order = $message->getContent();

-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

+		$channelName = $order['iced'] ? 'coldDrinks' : 'hotDrinks';

 		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

 		return $channelName;

 	}	

src/Data/Store.php

Spacing +7 added lines, -7 removed lines

@@ -34,7 +34,7 @@ 
      * @param mixed $value the value to store
      * @return 
      */
-    public function setValue($key, $value){
+    public function setValue($key, $value) {
         return $this->offsetSet($key, $value);
     }
     
@@ -45,7 +45,7 @@ 
      * @param mixed $key the key to return value for 
      * @return mixed the value for the given key
      */
-    public function getValue($key){
+    public function getValue($key) {
         return $this->offsetGet($key, $value);
     }
   
@@ -56,7 +56,7 @@ 
      * @param mixed $key the key to unset value for 
      * @return 
      */
-    public function deleteValue($key){
+    public function deleteValue($key) {
         return $this->offsetUnset($key);
     }
       
@@ -67,7 +67,7 @@ 
      * @param mixed $key the key to look for a value
      * @return boolean wether a value is stored for the key
      */
-    public function hasValue($key){
+    public function hasValue($key) {
         return $this->offsetExists($key);
     }   
 
@@ -78,7 +78,7 @@ 
      * @param array $values key/value pairs to store
      * @return 
      */
-    public function setValues(array $values){
+    public function setValues(array $values) {
         $this->values = $values;        
     }
 
@@ -88,7 +88,7 @@ 
      * @access public
      * @return array stored key/value pairs
      */
-    public function getValues(){
+    public function getValues() {
         return $this->values;
     }
    
@@ -100,7 +100,7 @@ 
      * @param $values 
      * @return 
      */
-    public function addValues(array $values){
+    public function addValues(array $values) {
         array_merge($this->values, $values);
     }   
 }
\ 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/Splitter/MessageSplitter.php

Spacing +6 added lines, -6 removed lines

@@ -35,9 +35,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);    
         }   
     }           
@@ -49,13 +49,13 @@ 
      * @param \PEIP\INF\Message\Message $message message to split 
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){     
+    public function doReply(\PEIP\INF\Message\Message $message) {     
         $res = $this->split($message);      
-        if(is_array($res)){
-            foreach($res as $msg){ 
+        if (is_array($res)) {
+            foreach ($res as $msg) { 
                 $this->replyMessage($msg);
             }
-        }else{
+        }else {
             $this->replyMessage($res);
         }
     }

Braces +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         $name = is_object($name) ? get_class($name) : (string)$name;
         if(Test::assertClassOrInterfaceExists($name)){
             parent::connect($name, $listener);
-        }else{
+        } else{
             throw new \InvalidArgumentException($name." is not an Class nor Interface");
         }
     }

src/Pipe/SimpleEventPipe.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      * @param $outputChannel 
      * @return 
      */
-    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel){
+    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel) {
         $this->setEventName($eventName);
         $this->setInputChannel($inputChannel);
         $this->setOutputChannel($outputChannel);        

src/Selector/ContentTypeSelector.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
      * @param $type 
      * @return 
      */
-    public function __construct($type){
+    public function __construct($type) {
         $this->type = $type;
     }       
             
@@ -57,7 +57,7 @@ 
      * @param $message 
      * @return 
      */
-    public function acceptMessage(\PEIP\INF\Message\Message $message){
+    public function acceptMessage(\PEIP\INF\Message\Message $message) {
         return call_user_func(self::$types[$this->type], $message->getContent());
     }           
     

src/Dispatcher/Dispatcher.php

Spacing +12 added lines, -12 removed lines

@@ -40,7 +40,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $listener
      * @return void
      */
-    public function connect($listener){
+    public function connect($listener) {
         Test::ensureHandler($listener);
         $this->listeners[] = $listener;
     }
@@ -52,10 +52,10 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return void
      */
-    public function disconnect($listener){
+    public function disconnect($listener) {
         Test::ensureHandler($listener);
-        foreach ($this->listeners as $i => $callable){
-            if ($listener === $callable){
+        foreach ($this->listeners as $i => $callable) {
+            if ($listener === $callable) {
                 unset($this->listeners[$i]);
             }
         }
@@ -68,7 +68,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return void
      */
-    public function disconnectAll(){
+    public function disconnectAll() {
         $this->listeners = array();
     }
 
@@ -78,8 +78,8 @@ 
      * @access public
      * @return boolean wether any listeners are registered
      */
-    public function hasListeners(){
-        return (boolean) count($this->listeners);
+    public function hasListeners() {
+        return (boolean)count($this->listeners);
     }
     
     /**
@@ -89,9 +89,9 @@ 
      * @param mixed $subject the subject
      * @return void
      */
-    public function notify($subject){
+    public function notify($subject) {
         $res = NULL;
-        if($this->hasListeners()){
+        if ($this->hasListeners()) {
             $res = self::doNotify($this->getListeners(), $subject); 
         }   
         return $res;      
@@ -104,8 +104,8 @@ 
      * @param mixed $subject the subject 
      * @return \PEIP\INF\Handler\Handler the listener which returned a boolean true value
      */
-    public function notifyUntil($subject){
-        if($this->hasListeners()){
+    public function notifyUntil($subject) {
+        if ($this->hasListeners()) {
             $res = self::doNotifyUntil($this->getListeners(), $subject);    
         }
         return $res;
@@ -117,7 +117,7 @@ 
      * @access public
      * @return array the listeners
      */
-    public function getListeners(){
+    public function getListeners() {
         return $this->listeners;
     }
 

src/Util/Reflection.php

Spacing +3 added lines, -3 removed lines

@@ -30,9 +30,9 @@ 
      * @return array array with interface/class info for the class
      */
 
-    public static function getImplementedClassesAndInterfaces($class, $store = true){
+    public static function getImplementedClassesAndInterfaces($class, $store = true) {
         $class = is_object($class) ? get_class($class) : (string)$class;
-        if(isset(self::$classInfo[$class])){
+        if (isset(self::$classInfo[$class])) {
             return self::$classInfo[$class];
         }
         $cls = ReflectionPool::getInstance($class);
@@ -40,7 +40,7 @@ 
         $classInfo = (array)$cls->getInterfaceNames();
         $classInfo[] = $cls->getName();
         // get names of parent-classes
-        while($cls = $cls->getParentClass()){
+        while ($cls = $cls->getParentClass()) {
             $classInfo[] = $cls->getName();
         }