Completed
Push — v1.ns ( 919dbc...ab319d )
by Timo
03:07
created
src/ABS/Dispatcher/Dispatcher.php 3 patches
Indentation   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -60,9 +60,9 @@
 block discarded – undo
60 60
      */     
61 61
     protected static function doNotifyUntil(array $listeners, $subject){
62 62
         foreach ($listeners as $listener){
63
-          if (self::doNotifyOne($listener, $subject)){
63
+            if (self::doNotifyOne($listener, $subject)){
64 64
             return $listener;
65
-          }
65
+            }
66 66
         }
67 67
         return NULL;
68 68
     } 
Please login to merge, or discard this patch.
Spacing   +8 added lines, -8 removed lines patch added patch discarded remove patch
@@ -33,16 +33,16 @@  discard block
 block discarded – undo
33 33
      * @param mixed $subject subject to notify the listeners of 
34 34
      * @return void
35 35
      */ 
36
-    protected static function doNotify(array $listeners, $subject){
37
-        foreach($listeners as $listener){
36
+    protected static function doNotify(array $listeners, $subject) {
37
+        foreach ($listeners as $listener) {
38 38
             self::doNotifyOne($listener, $subject);
39 39
         }   
40 40
     }  
41 41
 
42
-    protected static function doNotifyOne($listener, $subject){
43
-        if(is_callable($listener)){
42
+    protected static function doNotifyOne($listener, $subject) {
43
+        if (is_callable($listener)) {
44 44
             $res = call_user_func($listener, $subject);
45
-        }else{
45
+        }else {
46 46
             $res = $listener->handle($subject);
47 47
         }
48 48
         return $res;
@@ -58,9 +58,9 @@  discard block
 block discarded – undo
58 58
      * @param mixed $subject subject to notify the listeners of 
59 59
      * @return \PEIP\INF\Handler\Handler listener that returned a boolean true value
60 60
      */     
61
-    protected static function doNotifyUntil(array $listeners, $subject){
62
-        foreach ($listeners as $listener){
63
-          if (self::doNotifyOne($listener, $subject)){
61
+    protected static function doNotifyUntil(array $listeners, $subject) {
62
+        foreach ($listeners as $listener) {
63
+          if (self::doNotifyOne($listener, $subject)) {
64 64
             return $listener;
65 65
           }
66 66
         }
Please login to merge, or discard this patch.
Braces   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@
 block discarded – undo
17 17
     protected function getMessage($object){
18 18
         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){
19 19
             return $object; 
20
-        }else{
20
+        } else{
21 21
             return $object->getContent()->receive();
22 22
         }
23 23
     }
Please login to merge, or discard this patch.
src/ABS/Base/Container.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@  discard block
 block discarded – undo
22 22
 
23 23
 
24 24
 abstract class Container 
25
-    implements \PEIP\INF\Base\Container{
25
+    implements \PEIP\INF\Base\Container {
26 26
 
27 27
     protected $content;
28 28
        
@@ -33,7 +33,7 @@  discard block
 block discarded – undo
33 33
      * @access public
34 34
      * @return 
35 35
      */
36
-    public function getContent(){
36
+    public function getContent() {
37 37
         return $this->content;
38 38
     }
39 39
     
Please login to merge, or discard this patch.
src/ABS/Base/Connectable.php 2 patches
Spacing   +15 added lines, -15 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
  * @subpackage base 
18 18
  */
19 19
 
20
-abstract class Connectable  implements \PEIP\INF\Event\Connectable{
20
+abstract class Connectable  implements \PEIP\INF\Event\Connectable {
21 21
 
22 22
     const
23 23
         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',
@@ -42,7 +42,7 @@  discard block
 block discarded – undo
42 42
      * @param Callable|PEIP\INF\Handler\Handler $listener
43 43
      * @return
44 44
      */
45
-    public function connect($name, $listener){
45
+    public function connect($name, $listener) {
46 46
         \PEIP\Util\Test::ensureHandler($listener);
47 47
         $this->getEventDispatcher()->connect($name, $this, $listener);
48 48
         $this->doFireEvent(
@@ -61,7 +61,7 @@  discard block
 block discarded – undo
61 61
      * @param Callable|PEIP\INF\Handler\Handler $listener
62 62
      * @return
63 63
      */
64
-    public function disconnect($name, $listener){
64
+    public function disconnect($name, $listener) {
65 65
         \PEIP\Util\Test::ensureHandler($listener);
66 66
         $this->getEventDispatcher()->disconnect($name, $this, $listener);
67 67
         $this->doFireEvent(
@@ -82,7 +82,7 @@  discard block
 block discarded – undo
82 82
      * @param $name
83 83
      * @return
84 84
      */
85
-    public function hasListeners($name){
85
+    public function hasListeners($name) {
86 86
         return $this->getEventDispatcher()->hasListeners($name, $this);
87 87
     }
88 88
 
@@ -92,7 +92,7 @@  discard block
 block discarded – undo
92 92
      * @param $name
93 93
      * @return
94 94
      */
95
-    public function getListeners($name){
95
+    public function getListeners($name) {
96 96
         return $this->getEventDispatcher()->getListeners($name, $this);
97 97
     }
98 98
 
@@ -102,7 +102,7 @@  discard block
 block discarded – undo
102 102
      * @param $callable
103 103
      * @return
104 104
      */
105
-    public function disconnectAll($name){
105
+    public function disconnectAll($name) {
106 106
         $this->getEventDispatcher()->disconnectAll($name, $this);
107 107
     }
108 108
 
@@ -112,11 +112,11 @@  discard block
 block discarded – undo
112 112
      * @param $transferListners
113 113
      * @return
114 114
      */
115
-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){
116
-        if($transferListners){
117
-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){
118
-                if($this->getEventDispatcher()->hasListeners($name, $this)){
119
-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){
115
+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {
116
+        if ($transferListners) {
117
+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {
118
+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {
119
+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {
120 120
                         $dispatcher->connect($name, $this, $listener);
121 121
                     }
122 122
                 }
@@ -131,11 +131,11 @@  discard block
 block discarded – undo
131 131
      * @access public
132 132
      * @return
133 133
      */
134
-    public function getEventDispatcher(){
134
+    public function getEventDispatcher() {
135 135
         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();
136 136
     }
137 137
 
138
-    protected static function getSharedEventDispatcher(){
138
+    protected static function getSharedEventDispatcher() {
139 139
         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;
140 140
         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;
141 141
     }
@@ -148,12 +148,12 @@  discard block
 block discarded – undo
148 148
      * @param $eventClass
149 149
      * @return
150 150
      */
151
-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){
151
+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {
152 152
         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;
153 153
         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);
154 154
     }
155 155
 
156
-    protected static function getDefaultEventClass(){
156
+    protected static function getDefaultEventClass() {
157 157
         return self::DEFAULT_EVENT_CLASS;
158 158
     }
159 159
 }
Please login to merge, or discard this patch.
Doc Comments   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -38,7 +38,7 @@
 block discarded – undo
38 38
     
39 39
     /**
40 40
      * @access public
41
-     * @param $name
41
+     * @param string $name
42 42
      * @param Callable|PEIP\INF\Handler\Handler $listener
43 43
      * @return
44 44
      */
Please login to merge, or discard this patch.
src/ABS/Base/MutableContainer.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -32,7 +32,7 @@
 block discarded – undo
32 32
      * @access public
33 33
      * @return mixed content
34 34
      */
35
-    public function getContent(){
35
+    public function getContent() {
36 36
         return parent::getContent();
37 37
     } 
38 38
 }
39 39
\ No newline at end of file
Please login to merge, or discard this patch.
src/ABS/Pipe/EventPipe.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -38,8 +38,8 @@  discard block
 block discarded – undo
38 38
      * @param string $eventName name of the event to listen to 
39 39
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 
40 40
      */
41
-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){
42
-        if(!$connectable->hasListener($eventName, $this)){
41
+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {
42
+        if (!$connectable->hasListener($eventName, $this)) {
43 43
             $connectable->connect($eventName, $this);
44 44
             $this->connections[spl_object_hash($connectable)] = $connectable;   
45 45
         }   
@@ -52,8 +52,8 @@  discard block
 block discarded – undo
52 52
      * @param string $eventName name of the event to unlisten 
53 53
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 
54 54
      */
55
-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){
56
-        if(!$connectable->hasListener($eventName, $this)){
55
+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {
56
+        if (!$connectable->hasListener($eventName, $this)) {
57 57
             $connectable->disconnect($eventName, $this);
58 58
             unset($this->connections[spl_object_hash($connectable)]);   
59 59
         }   
@@ -65,7 +65,7 @@  discard block
 block discarded – undo
65 65
      * @access public
66 66
      * @return array array of \PEIP\INF\Event\Connectable instances
67 67
      */
68
-    public function doGetConnected(){
68
+    public function doGetConnected() {
69 69
         return array_values($this->connections);
70 70
     }
71 71
     
Please login to merge, or discard this patch.
src/ABS/Transformer/Transformer.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -37,9 +37,9 @@  discard block
 block discarded – undo
37 37
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 
38 38
      * @return 
39 39
      */
40
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
40
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
41 41
         $this->setInputChannel($inputChannel);
42
-        if(is_object($outputChannel)){
42
+        if (is_object($outputChannel)) {
43 43
             $this->setOutputChannel($outputChannel);    
44 44
         }   
45 45
     }           
@@ -51,7 +51,7 @@  discard block
 block discarded – undo
51 51
      * @param \PEIP\INF\Message\Message $message message to transform content 
52 52
      * @return 
53 53
      */
54
-    public function doReply(\PEIP\INF\Message\Message $message){     
54
+    public function doReply(\PEIP\INF\Message\Message $message) {     
55 55
         $this->replyMessage($this->transform($message));
56 56
     }
57 57
   
@@ -62,7 +62,7 @@  discard block
 block discarded – undo
62 62
      * @param \PEIP\INF\Message\Message $message 
63 63
      * @return mixed result of transforming the message 
64 64
      */
65
-    public function transform(\PEIP\INF\Message\Message $message){
65
+    public function transform(\PEIP\INF\Message\Message $message) {
66 66
         return $this->doTransform($message);
67 67
     }
68 68
 
Please login to merge, or discard this patch.
src/ABS/Transformer/ContentTransformer.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -34,7 +34,7 @@
 block discarded – undo
34 34
      * @param \PEIP\INF\Message\Message $message 
35 35
      * @return mixed result of transforming the message payload/content 
36 36
      */
37
-    protected function doTransform(\PEIP\INF\Message\Message $message){
37
+    protected function doTransform(\PEIP\INF\Message\Message $message) {
38 38
         return $this->transformContent($message->getContent());    
39 39
     }
40 40
 
Please login to merge, or discard this patch.
src/ABS/Channel/PollableChannel.php 3 patches
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -21,7 +21,7 @@
 block discarded – undo
21 21
  */
22 22
 
23 23
 
24
- class PollableChannel     
24
+    class PollableChannel     
25 25
     extends \PEIP\ABS\Channel\Channel
26 26
     implements \PEIP\INF\Channel\PollableChannel {
27 27
 
Please login to merge, or discard this patch.
Spacing   +12 added lines, -12 removed lines patch added patch discarded remove patch
@@ -34,7 +34,7 @@  discard block
 block discarded – undo
34 34
      * @param $message 
35 35
      * @return 
36 36
      */
37
-    protected function doSend(\PEIP\INF\Message\Message $message){
37
+    protected function doSend(\PEIP\INF\Message\Message $message) {
38 38
         $this->messages[] = $message;        
39 39
     }
40 40
     
@@ -44,17 +44,17 @@  discard block
 block discarded – undo
44 44
      * @param $timeout 
45 45
      * @return 
46 46
      */
47
-    public function receive($timeout = -1){
47
+    public function receive($timeout = -1) {
48 48
         $message = NULL;
49
-        if($timeout == 0){
49
+        if ($timeout == 0) {
50 50
             $message = $this->getMessage(); 
51
-        }elseif($timeout < 0){
52
-            while(!$message = $this->getMessage()){
51
+        }elseif ($timeout < 0) {
52
+            while (!$message = $this->getMessage()) {
53 53
                                 
54 54
             }
55
-        }else{
55
+        }else {
56 56
             $time = time() + $timeout;
57
-            while(($time > time()) && !$message = $this->getMessage()){
57
+            while (($time > time()) && !$message = $this->getMessage()) {
58 58
                 
59 59
             }       
60 60
         }
@@ -66,7 +66,7 @@  discard block
 block discarded – undo
66 66
      * @access protected
67 67
      * @return 
68 68
      */
69
-    protected function getMessage(){
69
+    protected function getMessage() {
70 70
         return array_shift($this->messages);
71 71
     }
72 72
     
@@ -75,7 +75,7 @@  discard block
 block discarded – undo
75 75
      * @access public
76 76
      * @return 
77 77
      */
78
-    public function clear(){
78
+    public function clear() {
79 79
         $this->messages = array();
80 80
     }
81 81
     
@@ -85,9 +85,9 @@  discard block
 block discarded – undo
85 85
      * @param $selector 
86 86
      * @return 
87 87
      */
88
-    public function purge(\PEIP\INF\Selector\MessageSelector $selector){
89
-        foreach($this->messages as $key=>$message){
90
-            if(!$selector->acceptMessage($message)){
88
+    public function purge(\PEIP\INF\Selector\MessageSelector $selector) {
89
+        foreach ($this->messages as $key=>$message) {
90
+            if (!$selector->acceptMessage($message)) {
91 91
                 unset($this->messages[$key]);   
92 92
             }
93 93
         }
Please login to merge, or discard this patch.
Braces   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -60,11 +60,11 @@
 block discarded – undo
60 60
         $message = NULL;
61 61
         if($timeout == 0){
62 62
             $message = $this->getMessage(); 
63
-        }elseif($timeout < 0){
63
+        } elseif($timeout < 0){
64 64
             while(!$message = $this->getMessage()){
65 65
                                 
66 66
             }
67
-        }else{
67
+        } else{
68 68
             $time = time() + $timeout;
69 69
             while(($time > time()) && !$message = $this->getMessage()){
70 70
                 
Please login to merge, or discard this patch.
src/ABS/Channel/SubscribableChannel.php 2 patches
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -29,7 +29,7 @@  discard block
 block discarded – undo
29 29
 
30 30
 abstract class SubscribableChannel 
31 31
     extends \PEIP\ABS\Channel\Channel
32
-    implements \PEIP\INF\Channel\SubscribableChannel{
32
+    implements \PEIP\INF\Channel\SubscribableChannel {
33 33
 
34 34
     protected $messageDispatcher;   
35 35
        
@@ -41,7 +41,7 @@  discard block
 block discarded – undo
41 41
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to subscribe
42 42
      * @return 
43 43
      */
44
-    public function subscribe($handler){ 
44
+    public function subscribe($handler) { 
45 45
         Test::ensureHandler($handler);
46 46
         $this->getMessageDispatcher()->connect($handler);
47 47
         $this->doFireEvent('subscribe', array('SUBSCRIBER'=>$handler));
@@ -55,7 +55,7 @@  discard block
 block discarded – undo
55 55
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to unsubscribe
56 56
      * @return 
57 57
      */
58
-    public function unsubscribe($handler){
58
+    public function unsubscribe($handler) {
59 59
         Test::ensureHandler($handler);
60 60
         $this->getMessageDispatcher()->disconnect($handler);
61 61
         $this->doFireEvent('unsubscribe', array('SUBSCRIBER'=>$handler));       
@@ -69,9 +69,9 @@  discard block
 block discarded – undo
69 69
      * @param boolean $transferListeners wether to transfer listeners of old dispatcher (if set) to new one. default: true 
70 70
      * @return 
71 71
      */
72
-    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true){
73
-        if(isset($this->dispatcher) && $transferListeners){
74
-            foreach($this->dispatcher->getListeners() as $listener){
72
+    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true) {
73
+        if (isset($this->dispatcher) && $transferListeners) {
74
+            foreach ($this->dispatcher->getListeners() as $listener) {
75 75
                 $dispatcher->connect($listener);
76 76
                 $this->dispatcher->disconnect($listener);       
77 77
             }   
@@ -85,7 +85,7 @@  discard block
 block discarded – undo
85 85
      * @access public
86 86
      * @return 
87 87
      */
88
-    public function getMessageDispatcher(){
88
+    public function getMessageDispatcher() {
89 89
         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new Dispatcher;
90 90
     }   
91 91
     
Please login to merge, or discard this patch.
Unused Use Statements   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -20,7 +20,7 @@
 block discarded – undo
20 20
  * @implements \PEIP\INF\Base\Container, \PEIP\INF\Message\Message, \PEIP\INF\Base\Buildable
21 21
  */
22 22
 
23
-use PEIP\Util\Test;
23
+use PEIP\Util\Test;
24 24
 use PEIP\Base\GenericBuilder;
25 25
 
26 26
 class GenericMessage 
Please login to merge, or discard this patch.