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