dazzle-php /
channel
| @@ 375-387 (lines=13) @@ | ||
| 372 | * @override |
|
| 373 | * @inheritDoc |
|
| 374 | */ |
|
| 375 | public function sendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 376 | { |
|
| 377 | $message = $this->createMessageProtocol($message); |
|
| 378 | ||
| 379 | $names = (array) $name; |
|
| 380 | $status = []; |
|
| 381 | foreach ($names as $name) |
|
| 382 | { |
|
| 383 | $status[] = $this->handleSendRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 384 | } |
|
| 385 | ||
| 386 | return !isset($status[0]) || isset($status[1]) ? $status : $status[0]; |
|
| 387 | } |
|
| 388 | ||
| 389 | /** |
|
| 390 | * @override |
|
| @@ 393-405 (lines=13) @@ | ||
| 390 | * @override |
|
| 391 | * @inheritDoc |
|
| 392 | */ |
|
| 393 | public function pushRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 394 | { |
|
| 395 | $message = $this->createMessageProtocol($message); |
|
| 396 | ||
| 397 | $names = (array) $name; |
|
| 398 | $status = []; |
|
| 399 | foreach ($names as $name) |
|
| 400 | { |
|
| 401 | $status[] = $this->handlePushRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 402 | } |
|
| 403 | ||
| 404 | return !isset($status[0]) || isset($status[1]) ? $status : $status[0]; |
|
| 405 | } |
|
| 406 | ||
| 407 | /** |
|
| 408 | * @override |
|
| @@ 390-402 (lines=13) @@ | ||
| 387 | * @override |
|
| 388 | * @inheritDoc |
|
| 389 | */ |
|
| 390 | public function sendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 391 | { |
|
| 392 | $protocol = $this->createMessageProtocol($message); |
|
| 393 | $names = (array) $name; |
|
| 394 | $handlers = []; |
|
| 395 | ||
| 396 | foreach ($names as $name) |
|
| 397 | { |
|
| 398 | $handlers[] = $this->handleSendRequest($name, $protocol, $flags, $success, $failure, $cancel, $timeout); |
|
| 399 | } |
|
| 400 | ||
| 401 | return !isset($handlers[0]) || isset($handlers[1]) ? $handlers : $handlers[0]; |
|
| 402 | } |
|
| 403 | ||
| 404 | /** |
|
| 405 | * @override |
|
| @@ 408-420 (lines=13) @@ | ||
| 405 | * @override |
|
| 406 | * @inheritDoc |
|
| 407 | */ |
|
| 408 | public function pushRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 409 | { |
|
| 410 | $protocol = $this->createMessageProtocol($message); |
|
| 411 | $names = (array) $name; |
|
| 412 | $handlers = []; |
|
| 413 | ||
| 414 | foreach ($names as $name) |
|
| 415 | { |
|
| 416 | $handlers[] = $this->handlePushRequest($name, $protocol, $flags, $success, $failure, $cancel, $timeout); |
|
| 417 | } |
|
| 418 | ||
| 419 | return !isset($handlers[0]) || isset($handlers[1]) ? $handlers : $handlers[0]; |
|
| 420 | } |
|
| 421 | ||
| 422 | /** |
|
| 423 | * @override |
|
