tidal / PEIP

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

         }

         

src/Util/ReflectionPool.php

Spacing +2 added lines, -2 removed lines

@@ -22,11 +22,11 @@
      * @param $argument

      * @return ReflectionClass

      */

-    public  static function getInstance($argument){

+    public  static function getInstance($argument) {

 

         $className = is_object($argument)

             ? get_class($argument)

-            : (string) $argument;

+            : (string)$argument;

         return isset(self::$instances[$className])

             ? self::$instances[$className]

             : self::$instances[$className] = new \ReflectionClass($className);

src/Event/Observable.php

Spacing +12 added lines, -12 removed lines

@@ -36,7 +36,7 @@ 
      * @param $observedObject 

      * @return 

      */

-    public function __construct(object $observedObject){

+    public function __construct(object $observedObject) {

         $this->observedObject = $observedObject;

     }

 

@@ -46,7 +46,7 @@ 
      * @param $observer 

      * @return 

      */

-    public function addObserver(\PEIP\INF\Event\Observer $observer){

+    public function addObserver(\PEIP\INF\Event\Observer $observer) {

         $this->observers[] = $observer;     

     }

 

@@ -56,9 +56,9 @@ 
      * @param $observer 

      * @return 

      */

-    public function deleteObserver(\PEIP\INF\Event\Observer $observer){

-        foreach($this->observers as $key=>$obs){

-            if($obs == $observer){

+    public function deleteObserver(\PEIP\INF\Event\Observer $observer) {

+        foreach ($this->observers as $key=>$obs) {

+            if ($obs == $observer) {

                 unset($this->observers[$key]);

                 return true;

             }

@@ -71,9 +71,9 @@ 
      * @param $arguments 

      * @return 

      */

-    public function notifyObservers(array $arguments = array()){

-        if($this->hasChanged()){

-            foreach($this->observers as $observer){

+    public function notifyObservers(array $arguments = array()) {

+        if ($this->hasChanged()) {

+            foreach ($this->observers as $observer) {

                 $observer->update($this->observedObject);

             }       

         }

@@ -84,7 +84,7 @@ 
      * @access public

      * @return 

      */

-    public function countObservers(){

+    public function countObservers() {

         return count($this->obeservers);

     }

     

@@ -93,7 +93,7 @@ 
      * @access public

      * @return 

      */

-    public function hasChanged(){

+    public function hasChanged() {

         return $this->hasChanged();

     }

     

@@ -102,7 +102,7 @@ 
      * @access public

      * @return 

      */

-    public function setChanged(){

+    public function setChanged() {

         $this->hasChanged = true;

     }

 

@@ -111,7 +111,7 @@ 
      * @access public

      * @return 

      */

-    public function clearChanged(){

+    public function clearChanged() {

         $this->hasChanged = true;   

     }

 

src/ABS/Dispatcher/Dispatcher.php

Indentation +2 added lines, -2 removed lines

@@ -60,9 +60,9 @@
      */     

     protected static function doNotifyUntil(array $listeners, $subject){

         foreach ($listeners as $listener){

-          if (self::doNotifyOne($listener, $subject)){

+            if (self::doNotifyOne($listener, $subject)){

             return $listener;

-          }

+            }

         }

         return NULL;

     } 

Spacing +8 added lines, -8 removed lines

@@ -33,16 +33,16 @@ 
      * @param mixed $subject subject to notify the listeners of 

      * @return void

      */ 

-    protected static function doNotify(array $listeners, $subject){

-        foreach($listeners as $listener){

+    protected static function doNotify(array $listeners, $subject) {

+        foreach ($listeners as $listener) {

             self::doNotifyOne($listener, $subject);

         }   

     }  

 

-    protected static function doNotifyOne($listener, $subject){

-        if(is_callable($listener)){

+    protected static function doNotifyOne($listener, $subject) {

+        if (is_callable($listener)) {

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

-        }else{

+        }else {

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

         }

         return $res;

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

@@ -17,7 +17,7 @@
     protected function getMessage($object){

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

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }

src/ABS/Base/Container.php

Spacing +2 added lines, -2 removed lines

@@ -22,7 +22,7 @@ 
 

 

 abstract class Container 

-    implements \PEIP\INF\Base\Container{

+    implements \PEIP\INF\Base\Container {

 

     protected $content;

        

@@ -33,7 +33,7 @@ 
      * @access public

      * @return 

      */

-    public function getContent(){

+    public function getContent() {

         return $this->content;

     }

     

src/ABS/Base/Connectable.php

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 

  */

 

-abstract class Connectable  implements \PEIP\INF\Event\Connectable{

+abstract class Connectable  implements \PEIP\INF\Event\Connectable {

 

     const

         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',

@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

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

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

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->connect($name, $this, $listener);

         $this->doFireEvent(

@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

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

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

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->disconnect($name, $this, $listener);

         $this->doFireEvent(

@@ -82,7 +82,7 @@ 
      * @param $name

      * @return

      */

-    public function hasListeners($name){

+    public function hasListeners($name) {

         return $this->getEventDispatcher()->hasListeners($name, $this);

     }

 

@@ -92,7 +92,7 @@ 
      * @param $name

      * @return

      */

-    public function getListeners($name){

+    public function getListeners($name) {

         return $this->getEventDispatcher()->getListeners($name, $this);

     }

 

@@ -102,7 +102,7 @@ 
      * @param $callable

      * @return

      */

-    public function disconnectAll($name){

+    public function disconnectAll($name) {

         $this->getEventDispatcher()->disconnectAll($name, $this);

     }

 

@@ -112,11 +112,11 @@ 
      * @param $transferListners

      * @return

      */

-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){

-        if($transferListners){

-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){

-                if($this->getEventDispatcher()->hasListeners($name, $this)){

-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){

+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {

+        if ($transferListners) {

+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {

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

+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {

                         $dispatcher->connect($name, $this, $listener);

                     }

                 }

@@ -131,11 +131,11 @@ 
      * @access public

      * @return

      */

-    public function getEventDispatcher(){

+    public function getEventDispatcher() {

         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();

     }

 

-    protected static function getSharedEventDispatcher(){

+    protected static function getSharedEventDispatcher() {

         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;

         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;

     }

@@ -148,12 +148,12 @@ 
      * @param $eventClass

      * @return

      */

-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){

+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {

         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;

         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);

     }

 

-    protected static function getDefaultEventClass(){

+    protected static function getDefaultEventClass() {

         return self::DEFAULT_EVENT_CLASS;

     }

 }

Doc Comments +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
     

     /**

      * @access public

-     * @param $name

+     * @param string $name

      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

src/ABS/Base/MutableContainer.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      * @access public

      * @return mixed content

      */

-    public function getContent(){

+    public function getContent() {

         return parent::getContent();

     } 

 }
\ 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);

     }