tidal / PEIP

src/Channel/DirectChannel.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
      * @param $timeout 
      * @return boolean wether message was sent successfully
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         return $this->doSend($message);
     }       
         
@@ -47,7 +47,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->getMessageDispatcher()->notify($message);
         return true;
     }
@@ -57,7 +57,7 @@ 
      * @access public
      * @return 
      */
-    public function getMessageDispatcher(){
+    public function getMessageDispatcher() {
         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new IteratingDispatcher;
     }   
     

src/Channel/QueueChannel.php

Spacing +7 added lines, -7 removed lines

@@ -37,7 +37,7 @@ 
      * @param $capacity 
      * @return 
      */
-    public function __construct($capacity = -1){
+    public function __construct($capacity = -1) {
         $this->setCapacity((int)$capacity);
         $this->queue = new SplQueue();  
     }   
@@ -47,7 +47,7 @@ 
      * @access public
      * @return 
      */
-    public function getMessageCount(){
+    public function getMessageCount() {
         return count($this->messages);
     }   
 
@@ -56,7 +56,7 @@ 
      * @access public
      * @return 
      */
-    public function getCapacity(){
+    public function getCapacity() {
         return $this->capacity;
     }       
 
@@ -66,7 +66,7 @@ 
      * @param $capacity 
      * @return 
      */
-    public function setCapacity($capacity){
+    public function setCapacity($capacity) {
         $this->capacity = $capacity;
     }   
 
@@ -76,10 +76,10 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
+        if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->enqueque($message);
-        }else{
+        }else {
             throw new \Exception('Not implemented yet.');
         }            
     }       

Braces +1 added lines, -1 removed lines

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

src/Channel/PollableChannel.php

Spacing +12 added lines, -12 removed lines

@@ -41,7 +41,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to send
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->messages[] = $message;
         return true;
     }
@@ -55,18 +55,18 @@ 
      * @param integer $timeout timout for receiving a message 
      * @return 
      */
-    public function receive($timeout = 0){
+    public function receive($timeout = 0) {
         $this->doFireEvent(self::EVENT_PRE_RECEIVE);
         $message = NULL;
-        if($timeout == 0){
+        if ($timeout == 0) {
             $message = $this->getMessage(); 
-        }elseif($timeout < 0){
-            while(!$message = $this->getMessage()){
+        }elseif ($timeout < 0) {
+            while (!$message = $this->getMessage()) {
                                 
             }
-        }else{
+        }else {
             $time = time() + $timeout;
-            while(($time > time()) && !$message = $this->getMessage()){
+            while (($time > time()) && !$message = $this->getMessage()) {
                 
             }       
         }
@@ -84,7 +84,7 @@ 
      * @access protected
      * @return \PEIP\INF\Message\Message message from top of the message stack
      */
-    protected function getMessage(){
+    protected function getMessage() {
         return array_shift($this->messages);
     }
        
@@ -94,7 +94,7 @@ 
      * @access public
      * @return 
      */
-    public function clear(){
+    public function clear() {
         $this->messages = array();
     }
         
@@ -105,9 +105,9 @@ 
      * @param \PEIP\INF\Message\Message_Selector $selector the selector to accept messages 
      * @return array accepted messages
      */
-    public function purge(\PEIP\INF\Selector\MessageSelector $selector){
-        foreach($this->messages as $key=>$message){
-            if(!$selector->acceptMessage($message)){
+    public function purge(\PEIP\INF\Selector\MessageSelector $selector) {
+        foreach ($this->messages as $key=>$message) {
+            if (!$selector->acceptMessage($message)) {
                 unset($this->messages[$key]);   
             }
         }

Braces +2 added lines, -2 removed lines

@@ -60,11 +60,11 @@
         $message = NULL;
         if($timeout == 0){
             $message = $this->getMessage(); 
-        }elseif($timeout < 0){
+        } elseif($timeout < 0){
             while(!$message = $this->getMessage()){
                                 
             }
-        }else{
+        } else{
             $time = time() + $timeout;
             while(($time > time()) && !$message = $this->getMessage()){
                 

src/Channel/PriorityChannel.php

Spacing +5 added lines, -5 removed lines

@@ -37,10 +37,10 @@ 
      * @param $priorityHeader 
      * @return 
      */
-    public function __construct($capacity = -1, $priorityHeader = NULL){
+    public function __construct($capacity = -1, $priorityHeader = NULL) {
         $this->setCapacity((int)$capacity);
         $this->queue = new SplPriorityQueue(); 
-        if($priorityHeader){
+        if ($priorityHeader) {
             $this->priorityHeader = $priorityHeader;
         }
     }   
@@ -51,10 +51,10 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
+    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.');
         }            
     }       

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/Channel/MessageChannel.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
      * @access public
      * @return 
      */
-    public function getName(){
+    public function getName() {
     
     }
 
@@ -40,7 +40,7 @@ 
      * @param $timeout 
      * @return 
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         
     }
 

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/Pipe/CommandPipe.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param $content 
      * @return 
      */
-    protected function replyMessage($content){
+    protected function replyMessage($content) {
         $message = $this->ensureMessage($content);      
         $this->getOutputChannel()->command($message);       
     }

src/Pipe/EventPipe.php

Spacing +13 added lines, -13 removed lines

@@ -29,7 +29,7 @@ 
     protected 
         $eventName; 
        
-    public function connectChannel(\PEIP\INF\Channel\Channel $inputChannel){
+    public function connectChannel(\PEIP\INF\Channel\Channel $inputChannel) {
         $this->inputChannel = $inputChannel;
         
     }
@@ -44,7 +44,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel to listen for events. 
      * @return 
      */
-    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){        
+    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {        
         $this->connectChannel($inputChannel);            
     }     
   
@@ -60,9 +60,9 @@ 
      * @access protected
      * @param \PEIP\INF\Message\Message $message the message to reply with
      */
-    protected function doReply(\PEIP\INF\Message\Message $message){
+    protected function doReply(\PEIP\INF\Message\Message $message) {
         $headerMessage = $message->getHeader('MESSAGE');
-        if($headerMessage instanceof \PEIP\INF\Message\Message){
+        if ($headerMessage instanceof \PEIP\INF\Message\Message) {
             return $this->replyMessage($headerMessage);
         }
     }
@@ -75,7 +75,7 @@ 
      * @param \PEIP\INF\Event\Connectable $connectable the connectable to listen to
      * @return 
      */
-    public function listen(\PEIP\INF\Event\Connectable $connectable){
+    public function listen(\PEIP\INF\Event\Connectable $connectable) {
         return $this->doListen($this->eventName, $connectable);     
     }
        
@@ -87,7 +87,7 @@ 
      * @param \PEIP\INF\Event\Connectable $connectable the connectable to unlisten  
      * @return 
      */
-    public function unlisten(\PEIP\INF\Event\Connectable $connectable){
+    public function unlisten(\PEIP\INF\Event\Connectable $connectable) {
         return $this->doUnlisten($this->eventName, $connectable);       
     }
      
@@ -97,7 +97,7 @@ 
      * @access public
      * @return array array of \PEIP\INF\Event\Connectable instances
      */
-    public function getConnected(){
+    public function getConnected() {
         return $this->doGetConnected();
     }
        
@@ -108,7 +108,7 @@ 
      * @param \PEIP\INF\Channel\Channel $channel \PEIP\INF\Channel\Channel instance to disconnect from
      * @return 
      */
-    public function disconnectChannel(\PEIP\INF\Channel\Channel $channel){
+    public function disconnectChannel(\PEIP\INF\Channel\Channel $channel) {
         $this->disconnectInputChannel();        
         $this->inputChannel = $channel;         
         $this->connectInputChannel();       
@@ -121,8 +121,8 @@ 
      * @access protected
      * @return 
      */
-    protected function connectInputChannel(){
-        if($this->inputChannel && $this->eventName){
+    protected function connectInputChannel() {
+        if ($this->inputChannel && $this->eventName) {
             $this->inputChannel->connect($this->eventName, $this);
         }   
     }
@@ -134,8 +134,8 @@ 
      * @access protected
      * @return 
      */
-    protected function disconnectInputChannel(){
-        if($this->inputChannel && $this->eventName){
+    protected function disconnectInputChannel() {
+        if ($this->inputChannel && $this->eventName) {
             $this->inputChannel->disconnect($this->eventName, $this);
         }       
     }
@@ -147,7 +147,7 @@ 
      * @param $eventName 
      * @return 
      */
-    public function setEventName($eventName){
+    public function setEventName($eventName) {
         $this->disconnectInputChannel();
         $this->eventName = $eventName;
         $this->connectInputChannel();

src/Base/Sealer.php

Spacing +3 added lines, -3 removed lines

@@ -38,7 +38,7 @@ 
      * @param ObjectStorage $store an instane of ObjectStorage to act as the internal object-store
      * @return 
      */
-    public function __construct(\SplObjectStorage $store = NULL){
+    public function __construct(\SplObjectStorage $store = NULL) {
         $this->store = (bool)$store ? $store : new ObjectStorage;    
     }   
       
@@ -53,7 +53,7 @@ 
      * @param object $box an object to act as the 'box'  
      * @return object the 'box' for the sealed value
      */
-    public function seal($value, $box = false){
+    public function seal($value, $box = false) {
         $box = (bool)$box ? $box : new \stdClass;
         $this->store[$box] = $value;        
         return $box;
@@ -66,7 +66,7 @@ 
      * @param object $box the box-object to return the value for. 
      * @return 
      */
-    public function unseal($box){
+    public function unseal($box) {
         return $this->store[$box];
     }
 }