tidal / PEIP

src/Dispatcher/ObjectEventDispatcher.php

Braces +2 added lines, -2 removed lines

@@ -46,10 +46,10 @@
                 if ($this->hasListeners($name, $object->getContent())) {
                     return self::doNotify($this->getListeners($name, $object->getContent()), $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');
         }  
     }   

src/INF/Dispatcher/ListDispatcher.php

Spacing +2 added lines, -2 removed lines

@@ -24,9 +24,9 @@
 
 interface ListDispatcher extends \PEIP\INF\Dispatcher\Dispatcher {
 
-    public function connect( $handler);
+    public function connect($handler);
 
-    public function disconnect( $handler);
+    public function disconnect($handler);
 
     public function hasListeners();
 

src/INF/Message/MessageDispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -26,11 +26,11 @@
 
     public function disconnect($name, \PEIP\INF\Message\MessageHandler $handler);
 
-    public function notify( $event);
+    public function notify($event);
 
-    public function notifyUntil( $event);
+    public function notifyUntil($event);
 
-    public function filter( $event, $value);
+    public function filter($event, $value);
 
     public function hasListeners($name);
 

src/Message/GenericMessage.php

Spacing +2 added lines, -2 removed lines

@@ -81,8 +81,8 @@
          * @access public
          * @return ArrayAccess ArrayAccess object of headers
          */
-    public function getHeaders(){
-        return (array) $this->headers;
+    public function getHeaders() {
+        return (array)$this->headers;
     }
   
     /**

Braces +2 added lines, -4 removed lines

@@ -134,12 +134,10 @@
         $res = false;
         try {
             $res = (string)$this->getContent();
-        }
-        catch (\Exception $e) {           
+        } catch (\Exception $e) {           
             try {
                 $res = get_class($this->getContent());
-            }
-            catch (\Exception $e) {
+            } catch (\Exception $e) {
                 return "";
             }
         }     

src/Message/CallableMessageHandler.php

Braces +3 added lines, -4 removed lines

@@ -56,11 +56,11 @@ 
                 if ($static && !$reflectionFunc->isStatic()) {
                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  
                 }
-            }else {
+            } else {
                 $reflectionFunc = new \ReflectionFunction($this->callable);  
             }
             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();
-        }else {
+        } else {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');
         }   
     }   
@@ -79,8 +79,7 @@ 
         }   
         try {
             return call_user_func_array($this->callable, array($message, $channel, $sent));
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());
         }   
     }   

src/Service/SplittingServiceActivator.php

Braces +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
     public function callService(\PEIP\INF\Message\Message $message) {
         if (is_callable($this->serviceCallable)) {
             $res = call_user_func_array($this->serviceCallable, $message->getContent());
-        }elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
+        } elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               
         }
         return $res;

src/Pipe/Pipe.php

Braces +1 added lines, -1 removed lines

@@ -108,7 +108,7 @@
         //if(\PEIP\Util\Test::assertMessage($message)){
             if ($this->getOutputChannel()) { 
                 $this->getOutputChannel()->send($message);
-            }else { 
+            } else { 
                 $this->doSend($message);
             }
         //}

src/ABS/Dispatcher/Dispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -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;
             }
         }

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     protected function doSend(\PEIP\INF\Message\Message $message) {
         if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->insert($message, $message->getHeader($this->priorityHeader));
-        }else {
+        } else {
             throw new \Exception('Not implemented yet.');
         }            
     }       

src/ABS/Dispatcher/MapDispatcher.php

Spacing +6 added lines, -6 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;
             }