tidal / PEIP

src/Dispatcher/ClassEventDispatcher.php

Indentation +15 added lines, -15 removed lines

@@ -67,9 +67,9 @@ 
                         Reflection_Pool::getInstance(

                             $object->getContent()

                         )

-                     ),

-                     $object

-                 );

+                        ),

+                        $object

+                    );

             }else{

                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');

             }

@@ -78,18 +78,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

-     * @see EventBuilder

-     */

+        /**

+         * 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

+         * @see EventBuilder

+         */

     public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

         if(!$this->hasListeners($name, ($object))){

             return false;

Spacing +13 added lines, -13 removed lines

@@ -27,9 +27,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener event-handler

      * @return boolean

      */

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

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

         $class = is_object($object) ? get_class($object) : (string)$object;

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = Reflection_Pool::getInstance($class);

             parent::connect($name, $reflection, $listener);

         }

@@ -37,13 +37,13 @@ 
         return true;

     }

 

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

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

         $class = is_object($object) ? get_class($object) : (string)$object;

         $res = true;

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = Reflection_Pool::getInstance($class);

             $r = parent::disconnect($name, $reflection, $listener);

-            if(!$r){

+            if (!$r) {

                 $res = false;

             }

         }

@@ -58,9 +58,9 @@ 
      * @param \PEIP\INF\Event\Event $object an event object

      * @return boolean

      */

-    public function notify($name, $object){ 

-        if($object instanceof \PEIP\INF\Event\Event){

-            if(is_object($object->getContent())){

+    public function notify($name, $object) { 

+        if ($object instanceof \PEIP\INF\Event\Event) {

+            if (is_object($object->getContent())) {

                 return self::doNotify(

                     $this->getListeners(

                         $name,

@@ -70,10 +70,10 @@ 
                      ),

                      $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');

         }

     }       //put your code here

@@ -90,8 +90,8 @@ 
      * @return

      * @see EventBuilder

      */

-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

-        if(!$this->hasListeners($name, ($object))){

+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {

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

             return false;

         }

 

@@ -114,7 +114,7 @@ 
      * @param object $object object to check for listeners

      * @return boolean

      */

-    public function hasListeners($name, $object){

+    public function hasListeners($name, $object) {

         return parent::hasListeners(

             $name,

             Reflection_Pool::getInstance($object)

Braces +2 added lines, -2 removed lines

@@ -70,10 +70,10 @@
                      ),

                      $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');

         }

     }       //put your code here

Doc Comments +2 added lines, -2 removed lines

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

      * @param string $name name of the event

      * @param \PEIP\INF\Event\Event $object an event object

-     * @return boolean

+     * @return boolean|null

      */

     public function notify($name, $object){ 

         if($object instanceof \PEIP\INF\Event\Event){

@@ -53,7 +53,7 @@ 
      * @param array $headers headers of the event-object as key/value pairs

      * @param string $eventClass event-class to create instances from

      * @return

-     * @see EventBuilder

+     boolean|null @see EventBuilder

      */

     public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

         if(!$this->hasListeners($name, ($object))){

Unused Use Statements +2 added lines, -2 removed lines

@@ -11,8 +11,8 @@
  *

  * @author timo

  */

-use PEIP\Util\Reflection;

-use PEIP\Util\ReflectionPool;

+use PEIP\Util\Reflection;
+use PEIP\Util\ReflectionPool;
 use PEIP\Event\EventBuilder;

 

 class ClassEventDispatcher extends \PEIP\Dispatcher\ObjectEventDispatcher {

src/Dispatcher/IteratingDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -41,11 +41,11 @@ 
      * @param mixed array|ArrayAccess array with values to iterate over

      * @return 

      */

-    public function __construct($array = array()){

+    public function __construct($array = array()) {

         $this->init($array);

     }

 

-    protected function init($array = array()){

+    protected function init($array = array()) {

         $array = Test::assertArrayAccess($array)

             ? $array

             : array();

@@ -59,7 +59,7 @@ 
      * @param mixed $listener the listener to register

      * @return 

      */

-    public function connect($listener){

+    public function connect($listener) {

         $this->listeners[] = $listener;

     }

 

@@ -70,9 +70,9 @@ 
      * @param mixed $listener the listener to unregister

      * @return 

      */

-    public function disconnect($listener){

-        foreach ($this->listeners as $i => $callable){

-            if ($listener === $callable){

+    public function disconnect($listener) {

+        foreach ($this->listeners as $i => $callable) {

+            if ($listener === $callable) {

                 unset($this->listeners[$i]);

             }

         }

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

      * @return

      */

-    public function disconnectAll(){

+    public function disconnectAll() {

         $this->init();

     }

 

@@ -95,8 +95,8 @@ 
      * @access public

      * @return boolean wether any listener is registered

      */

-    public function hasListeners(){

-        return (boolean) $this->listeners->count();

+    public function hasListeners() {

+        return (boolean)$this->listeners->count();

     }

 

     /**

@@ -108,10 +108,10 @@ 
      * @param mixed $subject the subject to notify about 

      * @return 

      */

-    public function notify($subject){

+    public function notify($subject) {

         $res = NULL;

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

-            if(!$this->listeners->valid()){

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

+            if (!$this->listeners->valid()) {

                 $this->listeners->rewind();

             }

             $res = self::doNotifyOne($this->listeners->current(), $subject);

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

      * @return array registered listeners 

      */

-    public function getListeners(){

+    public function getListeners() {

         return $this->listeners->getArrayCopy();

     }

     

src/Base/ObjectStorage.php

Spacing +1 added lines, -1 removed lines

@@ -20,4 +20,4 @@
 

 

 class ObjectStorage

-    extends \SplObjectStorage{}

+    extends \SplObjectStorage {}

src/Base/DynamicAdapter.php

Spacing +3 added lines, -3 removed lines

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

      * @return 

      */

-    public function __construct(\ArrayAccess $methodMap, $subject){

+    public function __construct(\ArrayAccess $methodMap, $subject) {

         $this->methodMap = $methodMap;

         $this->subject = $subject;      

     }

@@ -48,8 +48,8 @@ 
      * @param $arguments 

      * @return 

      */

-    public function __call($method, array $arguments){

-        if(array_key_exists($method, $this->methodMap)){

+    public function __call($method, array $arguments) {

+        if (array_key_exists($method, $this->methodMap)) {

             return call_user_func_array(array($this->subject, $this->methodMap[$method]), $arguments);

         }

     }

src/Base/VisitableArray.php

Spacing +4 added lines, -4 removed lines

@@ -24,7 +24,7 @@ 
 

 class VisitableArray 

     extends \RecursiveArrayIterator 

-    implements \PEIP\INF\Base\Visitable{

+    implements \PEIP\INF\Base\Visitable {

 

 

     

@@ -33,9 +33,9 @@ 
      * @param $visitor 

      * @return 

      */

-    public function acceptVisitor(\PEIP\INF\Base\Visitor $visitor){

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

-            foreach($this->getChildren as $child){

+    public function acceptVisitor(\PEIP\INF\Base\Visitor $visitor) {

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

+            foreach ($this->getChildren as $child) {

                 $child->acceptVisitor($visitor);

             }

         }

src/Base/ReflectionClassBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -32,7 +32,7 @@ 
      * @param string $className name of the class to return ReflectionClass for 

      * @return ReflectionClass the ReflectionClass instance for given class

      */    

-    protected static function getReflectionClass($className){

+    protected static function getReflectionClass($className) {

         return array_key_exists($className, self::$reflectionClasses) 

             ? self::$reflectionClasses[$className] 

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

@@ -47,7 +47,7 @@ 
      * @param string $className name of the class to return ReflectionClass for 

      * @return ReflectionClass the ReflectionClass instance for given class

      */     

-    public static function getInstance($className){

+    public static function getInstance($className) {

         return self::getReflectionClass($className);

     }

 

src/Base/FlyAdapter.php

Spacing +4 added lines, -4 removed lines

@@ -30,7 +30,7 @@ 
      * @param $methodMap 

      * @return 

      */

-    public function __construct(ArrayAccess $methodMap){        

+    public function __construct(ArrayAccess $methodMap) {        

         $this->methodMap = $methodMap;  

     }

     

@@ -40,7 +40,7 @@ 
      * @param $subject 

      * @return 

      */

-    public function setSubject($subject){

+    public function setSubject($subject) {

         $this->subject = $subject;

         return $this;

     }

@@ -52,8 +52,8 @@ 
      * @param $arguments 

      * @return 

      */

-    public function __call($method, $arguments){

-        if(array_key_exists($method, $this->methodMap)){

+    public function __call($method, $arguments) {

+        if (array_key_exists($method, $this->methodMap)) {

             return call_user_func_array(array($this->subject, $this->methodMap[$method]), $arguments);

         }

     }

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];

     }

 }

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