@@ -44,6 +44,9 @@ |
||
| 44 | 44 | return $this->{$name}; |
| 45 | 45 | } |
| 46 | 46 | |
| 47 | + /** |
|
| 48 | + * @param string $name |
|
| 49 | + */ |
|
| 47 | 50 | private function hasCollection($name) |
| 48 | 51 | { |
| 49 | 52 | return property_exists($this, $name) && is_a($this->{$name}, CollectionInterface::class); |
@@ -153,6 +153,9 @@ discard block |
||
| 153 | 153 | : $this->metaSubscriptionCollection = new SubscriptionCollection($this->session); |
| 154 | 154 | } |
| 155 | 155 | |
| 156 | + /** |
|
| 157 | + * @param string $procedure |
|
| 158 | + */ |
|
| 156 | 159 | protected function setInitialCall($procedure, callable $callback) |
| 157 | 160 | { |
| 158 | 161 | $this->initialCallProcedure = (string) $procedure; |
@@ -192,6 +195,9 @@ discard block |
||
| 192 | 195 | }; |
| 193 | 196 | } |
| 194 | 197 | |
| 198 | + /** |
|
| 199 | + * @param string $procedure |
|
| 200 | + */ |
|
| 195 | 201 | private function retrieveCallData($procedure, callable $filter = null, $arguments = []) |
| 196 | 202 | { |
| 197 | 203 | $deferred = new DeferredAdapter( |
@@ -204,6 +210,10 @@ discard block |
||
| 204 | 210 | |
| 205 | 211 | $this->session->call($procedure, $arguments) |
| 206 | 212 | ->then( |
| 213 | + |
|
| 214 | + /** |
|
| 215 | + * @param string $res |
|
| 216 | + */ |
|
| 207 | 217 | function ($res) use ($deferred, $filter) { |
| 208 | 218 | $deferred->resolve($filter($res)); |
| 209 | 219 | }, |
@@ -228,7 +238,7 @@ discard block |
||
| 228 | 238 | } |
| 229 | 239 | |
| 230 | 240 | /** |
| 231 | - * @param $event |
|
| 241 | + * @param string $event |
|
| 232 | 242 | * @return \Closure |
| 233 | 243 | */ |
| 234 | 244 | private function getSubscriptionHandler($event) |