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