@@ -504,6 +504,8 @@ discard block |
||
| 504 | 504 | /** |
| 505 | 505 | * @override |
| 506 | 506 | * @inheritDoc |
| 507 | + * @param ProtocolInterface $message |
|
| 508 | + * @param integer $flags |
|
| 507 | 509 | */ |
| 508 | 510 | protected function handleSendAsync($name, $message, $flags = Channel::MODE_DEFAULT) |
| 509 | 511 | { |
@@ -522,6 +524,8 @@ discard block |
||
| 522 | 524 | /** |
| 523 | 525 | * @override |
| 524 | 526 | * @inheritDoc |
| 527 | + * @param ProtocolInterface $message |
|
| 528 | + * @param integer $flags |
|
| 525 | 529 | */ |
| 526 | 530 | protected function handlePushAsync($name, $message, $flags = Channel::MODE_DEFAULT) |
| 527 | 531 | { |
@@ -552,6 +556,8 @@ discard block |
||
| 552 | 556 | /** |
| 553 | 557 | * @override |
| 554 | 558 | * @inheritDoc |
| 559 | + * @param ProtocolInterface $message |
|
| 560 | + * @param integer $flags |
|
| 555 | 561 | */ |
| 556 | 562 | protected function handleSendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
| 557 | 563 | { |
@@ -570,6 +576,8 @@ discard block |
||
| 570 | 576 | /** |
| 571 | 577 | * @override |
| 572 | 578 | * @inheritDoc |
| 579 | + * @param ProtocolInterface $message |
|
| 580 | + * @param integer $flags |
|
| 573 | 581 | */ |
| 574 | 582 | protected function handlePushRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
| 575 | 583 | { |
@@ -577,13 +577,13 @@ discard block |
||
| 577 | 577 | |
| 578 | 578 | /** |
| 579 | 579 | * @param string $name |
| 580 | - * @param string|ProtocolInterface $message |
|
| 580 | + * @param ProtocolInterface $message |
|
| 581 | 581 | * @param int $flags |
| 582 | 582 | * @param callable|null $success |
| 583 | 583 | * @param callable|null $failure |
| 584 | 584 | * @param callable|null $cancel |
| 585 | 585 | * @param float $timeout |
| 586 | - * @return bool[] |
|
| 586 | + * @return boolean |
|
| 587 | 587 | */ |
| 588 | 588 | protected function handleSendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
| 589 | 589 | { |
@@ -592,7 +592,7 @@ discard block |
||
| 592 | 592 | |
| 593 | 593 | /** |
| 594 | 594 | * @param string $name |
| 595 | - * @param string|ProtocolInterface $message |
|
| 595 | + * @param ProtocolInterface $message |
|
| 596 | 596 | * @param int $flags |
| 597 | 597 | * @param callable|null $success |
| 598 | 598 | * @param callable|null $failure |
@@ -665,7 +665,7 @@ discard block |
||
| 665 | 665 | } |
| 666 | 666 | |
| 667 | 667 | /** |
| 668 | - * @return int |
|
| 668 | + * @return string |
|
| 669 | 669 | */ |
| 670 | 670 | protected function getNextSuffix() |
| 671 | 671 | { |