| @@ 10-32 (lines=23) @@ | ||
| 7 | use React\Promise\PromiseInterface; |
|
| 8 | use function React\Promise\resolve; |
|
| 9 | ||
| 10 | final class RequestHandler |
|
| 11 | { |
|
| 12 | /** |
|
| 13 | * @var RequestService |
|
| 14 | */ |
|
| 15 | private $service; |
|
| 16 | ||
| 17 | /** |
|
| 18 | * @param RequestService $service |
|
| 19 | */ |
|
| 20 | public function __construct(RequestService $service) |
|
| 21 | { |
|
| 22 | $this->service = $service; |
|
| 23 | } |
|
| 24 | ||
| 25 | public function handle(RequestCommandInterface $command): PromiseInterface |
|
| 26 | { |
|
| 27 | return $this->service->handle( |
|
| 28 | $command->getRequest(), |
|
| 29 | $command->getOptions() |
|
| 30 | ); |
|
| 31 | } |
|
| 32 | } |
|
| 33 | ||
| @@ 10-32 (lines=23) @@ | ||
| 7 | use React\Promise\PromiseInterface; |
|
| 8 | use function React\Promise\resolve; |
|
| 9 | ||
| 10 | final class StreamingRequestHandler |
|
| 11 | { |
|
| 12 | /** |
|
| 13 | * @var StreamingRequestService |
|
| 14 | */ |
|
| 15 | private $service; |
|
| 16 | ||
| 17 | /** |
|
| 18 | * @param StreamingRequestService $service |
|
| 19 | */ |
|
| 20 | public function __construct(StreamingRequestService $service) |
|
| 21 | { |
|
| 22 | $this->service = $service; |
|
| 23 | } |
|
| 24 | ||
| 25 | public function handle(RequestCommandInterface $command): PromiseInterface |
|
| 26 | { |
|
| 27 | return $this->service->handle( |
|
| 28 | $command->getRequest(), |
|
| 29 | $command->getOptions() |
|
| 30 | ); |
|
| 31 | } |
|
| 32 | } |
|
| 33 | ||