|Request|null>|Promise|Request|null) */ private $mapper; /** * @psalm-param callable(Request):(\Generator|Request|null>|Promise|Request|null) $mapper */ public function __construct(callable $mapper) { $this->mapper = $mapper; } /** * @param Request $request * @param CancellationToken $cancellation * @param Stream $stream * * @return Promise */ final public function requestViaNetwork( Request $request, CancellationToken $cancellation, Stream $stream ): Promise { return call(function () use ($request, $cancellation, $stream) { $mappedRequest = yield call($this->mapper, $request); \assert($mappedRequest instanceof Request || $mappedRequest === null); return yield $stream->request($mappedRequest ?? $request, $cancellation); }); } public function request( Request $request, CancellationToken $cancellation, DelegateHttpClient $httpClient ): Promise { return call(function () use ($request, $cancellation, $httpClient) { $mappedRequest = yield call($this->mapper, $request); \assert($mappedRequest instanceof Request || $mappedRequest === null); return $httpClient->request($mappedRequest ?? $request, $cancellation); }); } }