tidal / PEIP

src/Pipe/FixedEventPipe.php

Braces +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
     public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){        

         if(isset($this->eventName)){

             $this->connectChannel($inputChannel);   

-        }else{

+        } else{

             $this->inputChannel = $inputChannel;    

         }               

     }       

src/Gateway/SimpleMessagingGateway.php

Braces +1 added lines, -2 removed lines

@@ -116,8 +116,7 @@
         $this->send($content);

         try {

             $res = $this->receive();

-        }

-        catch(\Exception $e){

+        } catch(\Exception $e){

             return NULL;

         }

         return $res;

src/Util/Test.php

Braces +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
             class_exists($className);
             $res =  ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);            
-        }  catch (\Exception $e){
+        } catch (\Exception $e){
             $res = false; 
         }
         return $res;;

src/ABS/Dispatcher/Dispatcher.php

Braces +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
     protected static function doNotifyOne($listener, $subject){

         if(is_callable($listener)){

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

-        }else{

+        } else{

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

         }

         return $res;

src/ABS/Channel/PollableChannel.php

Braces +2 added lines, -2 removed lines

@@ -48,11 +48,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/ABS/Handler/MessageHandler.php

Braces +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
         $this->inputChannel = $inputChannel;    

         if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){

                 $this->inputChannel->subscribe($this);

-        }else{          

+        } else{          

             $this->unwrapEvents = true;

             $this->inputChannel->connect('postSend', $this);

         }  

src/ABS/Splitter/MessageSplitter.php

Braces +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
             foreach($res as $msg){ 

                 $this->replyMessage($msg);

             }

-        }else{

+        } else{

             $this->replyMessage($res);

         }

     }

src/Plugins/BasePlugin.php

Braces +1 added lines, -1 removed lines

@@ -273,7 +273,7 @@
         $channel =  $this->services[trim((string)$channelName)];

         if($channel instanceof \PEIP\INF\Channel\Channel){

             return $channel;

-        }else{

+        } else{

             return NULL;

         }

     }

src/Autoload/Autoload.php

Braces +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
         while($iterator->valid()){

             if($iterator->isDir() && !$iterator->isDot()){

                 $paths = self::findPaths($baseDir, $iterator->getChildren(), $paths);

-            }elseif($iterator->isFile() && strrchr($iterator->getFilename(), '.') == '.php'){

+            } elseif($iterator->isFile() && strrchr($iterator->getFilename(), '.') == '.php'){

                 $class = $iterator->getBasename('.php');

                 $paths[$class] = str_replace($baseDir, '', $iterator->getPathName());                       

             }