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