tidal / PEIP

examples/Cafe/lib/messaging/DrinkAggregator.php

Spacing +7 added lines, -7 removed lines

@@ -9,30 +9,30 @@
     protected $orders = array();

     protected $preparedDrinks = array();

 	

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

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

         $this->setInputChannel($inputChannel);

-        if(is_object($outputChannel)){

+        if (is_object($outputChannel)) {

             $this->setOutputChannel($outputChannel);	

         }

         $this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

     }

 

-    protected function doReply(Message $message){

+    protected function doReply(Message $message) {

         $drink = $message->getContent();

         $nr = $drink->getOrderNumber();

-        if(!isset($this->preparedDrinks[$nr])){

+        if (!isset($this->preparedDrinks[$nr])) {

             $this->preparedDrinks[$nr] = array();

         }

         $this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

-        if(isset($this->orders[$nr]) 

-            && $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

+        if (isset($this->orders[$nr]) 

+            && $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])) {

             $this->replyMessage($this->preparedDrinks[$nr]);

             unset($this->preparedDrinks[$nr]);

             echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

         }

     }

 

-    public function receiveOrder(Order $order){

+    public function receiveOrder(Order $order) {

         echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

         $this->orders[$order->getOrderNumber()] = $order;	

     }	

examples/Cafe/lib/messaging/OrderSplitter.php

Spacing +3 added lines, -3 removed lines

@@ -5,15 +5,15 @@
 

 class OrderSplitter extends MessageSplitter {

 

-    public function split(Message $message){

+    public function split(Message $message) {

         $order = $message->getContent();

         $orderItems = $order->getItems();

         $items = array();

-        foreach($orderItems as $item){

+        foreach ($orderItems as $item) {

             $nr = $item['number'];

             unset($item['number']);

             $item['order'] = $order->getOrderNumber();

-            for($x = 0; $x < $nr; $x++){

+            for ($x = 0; $x < $nr; $x++) {

                 $items[] = $item;	

             }

         }

examples/Cafe/example.php

Braces +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
                 

     	}	

 

-}else {

+} else {

 	throw new RuntimeException('Could not get CafeGateway');

 }

 

src/Dispatcher/ObjectMapDispatcher.php

Spacing +4 added lines, -4 removed lines

@@ -207,11 +207,11 @@
      * @param $object 
      * @return boolean|null
      */    
-    protected static function doNotify(array $listeners, $subject){
-        foreach($listeners as $listener){ 
-                if($listener instanceof \PEIP\INF\Handler\Handler){
+    protected static function doNotify(array $listeners, $subject) {
+        foreach ($listeners as $listener) { 
+                if ($listener instanceof \PEIP\INF\Handler\Handler) {
                 $listener->handle($subject);
-                }elseif(is_callable($listener)){
+                }elseif (is_callable($listener)) {
                     call_user_func($listener, $subject);
                 }
         }   

Braces +2 added lines, -2 removed lines

@@ -104,7 +104,7 @@ 
         $listners = $this->doGetListeners();
         if (!$this->hadListeners($name, $object)) {
             $res = false;
-        }else {
+        } else {
             $listners = $this->doGetListeners();
             $res = (boolean)count($listners[$object][$name]);
         }
@@ -211,7 +211,7 @@ 
         foreach($listeners as $listener){ 
                 if($listener instanceof \PEIP\INF\Handler\Handler){
                 $listener->handle($subject);
-                }elseif(is_callable($listener)){
+                } elseif(is_callable($listener)){
                     call_user_func($listener, $subject);
                 }
         }   

src/Dispatcher/EventClassDispatcher.php

Indentation +11 added lines, -11 removed lines

@@ -43,18 +43,18 @@
         }
     }       //put your code here
 
-     /**
-     * Creates an event-object with given object as content/subject and notifies
-     * all registers listeners of the event.
-     *
-     * @access public
-     * @param string $name name of the event
-     * @param object $object the subject of the event
-     * @param array $headers headers of the event-object as key/value pairs
-     * @param string $eventClass event-class to create instances from
-     * @return
+        /**
+         * Creates an event-object with given object as content/subject and notifies
+         * all registers listeners of the event.
+         *
+         * @access public
+         * @param string $name name of the event
+         * @param object $object the subject of the event
+         * @param array $headers headers of the event-object as key/value pairs
+         * @param string $eventClass event-class to create instances from
+         * @return
      boolean|null @see EventBuilder
-     */
+         */
     public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {
         if (!$this->hasListeners($name, ($object))) {
             return false;

Spacing +2 added lines, -2 removed lines

@@ -35,10 +35,10 @@
                         ),
                         $object->getContent()
                     );
-            }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

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/Dispatcher/ClassDispatcher.php

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