@@ -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) |