@@ -60,9 +60,9 @@ |
||
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 | } |
@@ -33,16 +33,16 @@ discard block |
||
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 |
||
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 | } |
@@ -17,7 +17,7 @@ |
||
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 | } |
@@ -22,7 +22,7 @@ discard block |
||
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 |
||
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 |
@@ -17,7 +17,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | } |
@@ -38,7 +38,7 @@ |
||
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 | */ |
@@ -32,7 +32,7 @@ |
||
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 |
@@ -38,8 +38,8 @@ discard block |
||
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 |
||
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 |
||
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 |
@@ -37,9 +37,9 @@ discard block |
||
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 |
||
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 |
||
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 |
@@ -34,7 +34,7 @@ |
||
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 |
@@ -21,7 +21,7 @@ |
||
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 |
@@ -34,7 +34,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | } |
@@ -60,11 +60,11 @@ |
||
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 |
@@ -29,7 +29,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
@@ -20,7 +20,7 @@ |
||
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 |