tidal / PEIP

src/Listener/Wiretap.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@ 
      * @param $outputChannel 
      * @return 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->setEventName('preSend');
         $this->setInputChannel($inputChannel);
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);
         }           
     }           
@@ -47,7 +47,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doReply(\PEIP\INF\Message\Message $message){
+    protected function doReply(\PEIP\INF\Message\Message $message) {
         $this->replyMessage($message->getHeader('MESSAGE'));
     }
     

src/Handler/CallableHandler.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param callable $callable the callable to wrap with the handler 
      * @return 
      */
-    public function __construct($callable){
+    public function __construct($callable) {
         $this->callable = $callable;    
     }
         
@@ -45,7 +45,7 @@ 
      * @param mixed $subject the subject to handle
      * @return mixed result of calling the registered callable with given subject
      */
-    public function handle($subject){
+    public function handle($subject) {
         return call_user_func($this->callable, $subject);
     }
     
@@ -58,7 +58,7 @@ 
      * @return mixed result of calling the registered callable with given subject
      * @see CallableHandler::handle 
      */
-    public function __invoke($subject){
+    public function __invoke($subject) {
         return $this->handle($subject); 
     }
     
@@ -68,7 +68,7 @@ 
      * @access public
      * @return callable callable wrapped by the handler
      */
-    public function getCallable(){
+    public function getCallable() {
         return $this->callable;
     }
     

src/Event/Observable.php

Indentation +4 added lines, -4 removed lines

@@ -49,10 +49,10 @@
     }
 
         /**
-     * @access public
-     * @param $observer 
-     * @return 
-     */
+         * @access public
+         * @param $observer 
+         * @return 
+         */
     public function addObserver(\PEIP\INF\Event\Observer $observer){
         $this->observers[] = $observer;     
     }

Spacing +14 added lines, -14 removed lines

@@ -36,12 +36,12 @@ 
      * @param $observedObject 
      * @return 
      */
-    public function __construct($observedObject){
+    public function __construct($observedObject) {
         $this->setObserved($observedObject);
     }
 
-    protected function setObserved($observedObject){
-        if(!is_object($observedObject)){
+    protected function setObserved($observedObject) {
+        if (!is_object($observedObject)) {
             throw new \InvalidArgumentException("$observedObject must be an object. ".gettype($var)." given.");
         }
         
@@ -53,7 +53,7 @@ 
      * @param $observer 
      * @return 
      */
-    public function addObserver(\PEIP\INF\Event\Observer $observer){
+    public function addObserver(\PEIP\INF\Event\Observer $observer) {
         $this->observers[] = $observer;     
     }
 
@@ -63,9 +63,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;
             }
@@ -78,9 +78,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);
             }       
         }
@@ -91,7 +91,7 @@ 
      * @access public
      * @return 
      */
-    public function countObservers(){
+    public function countObservers() {
         return count($this->obeservers);
     }
     
@@ -100,7 +100,7 @@ 
      * @access public
      * @return 
      */
-    public function hasChanged(){
+    public function hasChanged() {
         return $this->hasChanged();
     }
     
@@ -109,7 +109,7 @@ 
      * @access public
      * @return 
      */
-    public function setChanged(){
+    public function setChanged() {
         $this->hasChanged = true;
     }
 
@@ -118,7 +118,7 @@ 
      * @access public
      * @return 
      */
-    public function clearChanged(){
+    public function clearChanged() {
         $this->hasChanged = true;   
     }
 

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