Set correct timeout in ConnectContext

amphp · Aug 2, 2019 · ac5d90e · ac5d90e
1 parent 7caa006
commit ac5d90e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Connection/DefaultConnectionPool.php b/src/Connection/DefaultConnectionPool.php
@@ -87,7 +87,7 @@ public function getConnection(Request $request, CancellationToken $cancellation)
                     $checkoutCancellationToken = new CombinedCancellationToken($cancellation, new TimeoutCancellationToken($request->getTcpConnectTimeout()));
 
                     /** @var EncryptableSocket $socket */
-                    $socket = yield $this->connector->connect('tcp://' . $authority, $connectContext, $checkoutCancellationToken);
+                    $socket = yield $this->connector->connect('tcp://' . $authority, $connectContext->withConnectTimeout($request->getTcpConnectTimeout()), $checkoutCancellationToken);
                 } catch (Socket\ConnectException $e) {
                     throw new SocketException(\sprintf("Connection to '%s' failed", $authority), 0, $e);
                 } catch (CancelledException $e) {