Add inactivity timeout to TO interceptor

README.md

@@ -234,6 +234,7 @@ The big disadvantage of network interceptors is that they have to be rather quic
 - `SetRequestHeaderIfUnset`
 - `SetResponseHeader`
 - `SetResponseHeaderIfUnset`
+- `SetRequestTimeout`
 - [`CookieHandler`](https://github.com/amphp/http-client-cookies)
 - [`PrivateCache`](https://github.com/amphp/http-client-cache)
 

src/Interceptor/SetRequestTimeout.php

@@ -10,15 +10,18 @@ public function __construct(
  float $tcpConnectTimeout = 10,
  float $tlsHandshakeTimeout = 10,
  float $transferTimeout = 10,
+ float $inactivityTimeout = 10,
  ) {
  parent::__construct(static function (Request $request) use (
  $tcpConnectTimeout,
  $tlsHandshakeTimeout,
- $transferTimeout
+ $transferTimeout,
+ $inactivityTimeout
  ) {
  $request->setTcpConnectTimeout($tcpConnectTimeout);
  $request->setTlsHandshakeTimeout($tlsHandshakeTimeout);
  $request->setTransferTimeout($transferTimeout);
+ $request->setInactivityTimeout($inactivityTimeout);
 
  return $request;
  });

test/TimeoutTest.php

@@ -242,4 +242,37 @@ public function testTimeoutDuringTlsEnableInterceptor(): void
  $server->close();
  }
  }
+
+ public function testTimeoutDuringInactivity(): void
+ {
+ $server = listen("tcp://127.0.0.1:0");
+
+ EventLoop::queue(static function () use ($server): void {
+ while ($client = $server->accept()) {
+ $client->write("HTTP/1.1 200 OK\r\nContent-Length: 2\r\n\r\n.");
+
+ EventLoop::unreference(EventLoop::delay(3, static function () use ($client): void {
+ $client->close();
+ }));
+ }
+ });
+
+ $this->setTimeout(2);
+
+ try {
+ $uri = "http://" . $server->getAddress() . "/";
+
+ $request = new Request($uri);
+
+ $client = new InterceptedHttpClient(new PooledHttpClient, new SetRequestTimeout(10, 10, 10, 1), []);
+ $response = $client->request($request, new NullCancellation);
+
+ $this->expectException(StreamException::class);
+ $this->expectExceptionMessage("HTTP response did not complete: Inactivity timeout exceeded, more than 1 seconds elapsed from last data received");
+
+ $response->getBody()->buffer();
+ } finally {
+ $server->close();
+ }
+ }
 }