tidal /
WampWatch
| @@ 347-358 (lines=12) @@ | ||
| 344 | * @param string $procedureName |
|
| 345 | * @param mixed $result |
|
| 346 | */ |
|
| 347 | public function respondToCall($procedureName, $result) |
|
| 348 | { |
|
| 349 | if (!isset($this->calls[$procedureName])) { |
|
| 350 | throw new UnknownProcedureException($procedureName); |
|
| 351 | } |
|
| 352 | ||
| 353 | /* @var $futureResult Deferred */ |
|
| 354 | $futureResult = $this->calls[$procedureName]; |
|
| 355 | unset($this->calls[$procedureName]); |
|
| 356 | ||
| 357 | $futureResult->resolve($result); |
|
| 358 | } |
|
| 359 | ||
| 360 | /** |
|
| 361 | * @param string $procedureName |
|
| @@ 364-375 (lines=12) @@ | ||
| 361 | * @param string $procedureName |
|
| 362 | * @param mixed $error |
|
| 363 | */ |
|
| 364 | public function failCall($procedureName, $error) |
|
| 365 | { |
|
| 366 | if (!isset($this->calls[$procedureName])) { |
|
| 367 | throw new UnknownProcedureException($procedureName); |
|
| 368 | } |
|
| 369 | ||
| 370 | /* @var $futureResult Deferred */ |
|
| 371 | $futureResult = $this->calls[$procedureName]; |
|
| 372 | unset($this->calls[$procedureName]); |
|
| 373 | ||
| 374 | $futureResult->reject($error); |
|
| 375 | } |
|
| 376 | ||
| 377 | /** |
|
| 378 | * @param string $procedureName |
|
