Lines Matching refs:request

33      * @param RequestInterface $request Request to send.
36 public function __invoke(RequestInterface $request, array $options): PromiseInterface argument
47 $request = $request->withoutHeader('Expect');
51 if (0 === $request->getBody()->getSize()) {
52 $request = $request->withHeader('Content-Length', '0');
56 $request,
58 $this->createStream($request, $options),
72 $e = new ConnectException($e->getMessage(), $request, $e);
74 $e = RequestException::wrapException($request, $e);
76 $this->invokeStats($options, $request, $startTime, null, $e);
84 RequestInterface $request, argument
90 … $stats = new TransferStats($request, $response, Utils::currentTime() - $startTime, $error, []);
98 …private function createResponse(RequestInterface $request, array $options, $stream, ?float $startT… argument
107 … new RequestException('An error was encountered while creating the response', $request, null, $e)
115 if (\strcasecmp('HEAD', $request->getMethod())) {
123 … new RequestException('An error was encountered while creating the response', $request, null, $e)
132 …w RequestException('An error was encountered during the on_headers event', $request, $response, $e)
143 $this->invokeStats($options, $request, $startTime, $response, null);
263 private function createStream(RequestInterface $request, array $options) argument
270 if (!\in_array($request->getUri()->getScheme(), ['http', 'https'])) {
271 …xception(\sprintf("The scheme '%s' is not supported.", $request->getUri()->getScheme()), $request);
276 if ($request->getProtocolVersion() == '1.1'
277 && !$request->hasHeader('Connection')
279 $request = $request->withHeader('Connection', 'close');
288 $context = $this->getDefaultContext($request);
298 $this->{$method}($request, $context, $value, $params);
315 $uri = $this->resolveHost($request, $options);
324 … function () use ($uri, &$http_response_header, $contextResource, $context, $options, $request) {
329 …row new ConnectException(sprintf('Connection refused for URI %s', $uri), $request, null, $context);
344 private function resolveHost(RequestInterface $request, array $options): UriInterface argument
346 $uri = $request->getUri();
352 …nectException(\sprintf("Could not resolve IPv4 address for host '%s'", $uri->getHost()), $request);
360 …nectException(\sprintf("Could not resolve IPv6 address for host '%s'", $uri->getHost()), $request);
370 private function getDefaultContext(RequestInterface $request): array argument
373 foreach ($request->getHeaders() as $name => $value) {
381 'method' => $request->getMethod(),
383 'protocol_version' => $request->getProtocolVersion(),
388 'peer_name' => $request->getUri()->getHost(),
392 $body = (string) $request->getBody();
397 if (!$request->hasHeader('Content-Type')) {
410 …private function add_proxy(RequestInterface $request, array &$options, $value, array &$params): vo… argument
417 $scheme = $request->getUri()->getScheme();
419 …if (!isset($value['no']) || !Utils::isHostInNoProxy($request->getUri()->getHost(), $value['no'])) {
471 …private function add_timeout(RequestInterface $request, array &$options, $value, array &$params): … argument
481 …private function add_crypto_method(RequestInterface $request, array &$options, $value, array &$par… argument
500 …private function add_verify(RequestInterface $request, array &$options, $value, array &$params): v… argument
526 …private function add_cert(RequestInterface $request, array &$options, $value, array &$params): void argument
543 …private function add_progress(RequestInterface $request, array &$options, $value, array &$params):… argument
560 …private function add_debug(RequestInterface $request, array &$options, $value, array &$params): vo… argument
581 $ident = $request->getMethod().' '.$request->getUri()->withFragment('');