diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index 0724232..28a6fd3 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -8,6 +8,7 @@ jobs:
   PHPUnit:
     name: PHPUnit (PHP ${{ matrix.php }})
     runs-on: ubuntu-20.04
+    timeout-minutes: 5
     strategy:
       matrix:
         php:
diff --git a/tests/FunctionalTest.php b/tests/FunctionalTest.php
index dc8702f..459befa 100644
--- a/tests/FunctionalTest.php
+++ b/tests/FunctionalTest.php
@@ -18,6 +18,7 @@ class FunctionalTest extends TestCase
     private $connector;
     private $client;
 
+    private $socket;
     private $port;
     private $server;
 
@@ -26,8 +27,8 @@ class FunctionalTest extends TestCase
      */
     public function setUpClientServer()
     {
-        $socket = new SocketServer('127.0.0.1:0');
-        $address = $socket->getAddress();
+        $this->socket = new SocketServer('127.0.0.1:0');
+        $address = $this->socket->getAddress();
         if (strpos($address, '://') === false) {
             $address = 'tcp://' . $address;
         }
@@ -35,11 +36,19 @@ public function setUpClientServer()
         $this->assertNotEquals(0, $this->port);
 
         $this->server = new Server();
-        $this->server->listen($socket);
+        $this->server->listen($this->socket);
         $this->connector = new TcpConnector();
         $this->client = new Client('127.0.0.1:' . $this->port, $this->connector);
     }
 
+    /**
+     * @after
+     */
+    public function closeSocket()
+    {
+        $this->socket->close();
+    }
+
     /** @group internet */
     public function testConnection()
     {
@@ -115,6 +124,8 @@ public function testConnectionSocksOverTls()
         $this->client = new Client(str_replace('tls:', 'sockss:', $socket->getAddress()), $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /**
@@ -144,6 +155,8 @@ public function testConnectionSocksOverTlsUsesPeerNameFromSocksUri()
         $this->client = new Client(str_replace('tls:', 'sockss:', $socket->getAddress()), $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -164,6 +177,8 @@ public function testConnectionSocksOverUnix()
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
 
         unlink($path);
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -184,6 +199,8 @@ public function testConnectionSocks5OverUnix()
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
 
         unlink($path);
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -204,6 +221,8 @@ public function testConnectionSocksWithAuthenticationOverUnix()
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
 
         unlink($path);
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -218,6 +237,8 @@ public function testConnectionAuthenticationFromUri()
         $this->client = new Client('name:pass@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -242,6 +263,8 @@ public function testConnectionAuthenticationCallback()
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
         $this->assertEquals(1, $called);
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -262,6 +285,8 @@ public function testConnectionAuthenticationCallbackWillNotBeInvokedIfClientsSen
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'));
         $this->assertEquals(0, $called);
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -276,6 +301,8 @@ public function testConnectionAuthenticationFromUriEncoded()
         $this->client = new Client(rawurlencode('name') . ':' . rawurlencode('p@ss:w0rd') . '@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -290,6 +317,8 @@ public function testConnectionAuthenticationFromUriWithOnlyUserAndNoPassword()
         $this->client = new Client('empty@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -304,6 +333,8 @@ public function testConnectionAuthenticationEmptyPassword()
         $this->client = new Client('user@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertResolveStream($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     /** @group internet */
@@ -325,6 +356,8 @@ public function testConnectionInvalidNoAuthenticationOverLegacySocks4()
         $this->client = new Client('socks4://127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'));
+
+        $socket->close();
     }
 
     public function testConnectionInvalidNoAuthentication()
@@ -338,6 +371,8 @@ public function testConnectionInvalidNoAuthentication()
         $this->client = new Client('socks5://127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'), null, defined('SOCKET_EACCES') ? SOCKET_EACCES : 13);
+
+        $socket->close();
     }
 
     public function testConnectionInvalidAuthenticationMismatch()
@@ -351,6 +386,8 @@ public function testConnectionInvalidAuthenticationMismatch()
         $this->client = new Client('user:pass@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'), null, defined('SOCKET_EACCES') ? SOCKET_EACCES : 13);
+
+        $socket->close();
     }
 
     public function testConnectionInvalidAuthenticatorReturnsFalse()
@@ -366,6 +403,8 @@ public function testConnectionInvalidAuthenticatorReturnsFalse()
         $this->client = new Client('user:pass@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'), null, defined('SOCKET_EACCES') ? SOCKET_EACCES : 13);
+
+        $socket->close();
     }
 
     public function testConnectionInvalidAuthenticatorReturnsPromiseFulfilledWithFalse()
@@ -381,6 +420,8 @@ public function testConnectionInvalidAuthenticatorReturnsPromiseFulfilledWithFal
         $this->client = new Client('user:pass@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'), null, defined('SOCKET_EACCES') ? SOCKET_EACCES : 13);
+
+        $socket->close();
     }
 
     public function testConnectionInvalidAuthenticatorReturnsPromiseRejected()
@@ -396,6 +437,8 @@ public function testConnectionInvalidAuthenticatorReturnsPromiseRejected()
         $this->client = new Client('user:pass@127.0.0.1:' . $this->port, $this->connector);
 
         $this->assertRejectPromise($this->client->connect('www.google.com:80'), null, defined('SOCKET_EACCES') ? SOCKET_EACCES : 13);
+
+        $socket->close();
     }
 
     /** @group internet */