diff --git a/package-lock.json b/package-lock.json
index c3d1eb1..3977893 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,12 +1,12 @@
 {
   "name": "@socket.io/redis-streams-adapter",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "@socket.io/redis-streams-adapter",
-      "version": "0.2.0",
+      "version": "0.2.1",
       "license": "MIT",
       "dependencies": {
         "@msgpack/msgpack": "~2.8.0",
@@ -2709,9 +2709,9 @@
       "dev": true
     },
     "node_modules/socket.io": {
-      "version": "4.7.4",
-      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.7.4.tgz",
-      "integrity": "sha512-DcotgfP1Zg9iP/dH9zvAQcWrE0TtbMVwXmlV4T4mqsvY+gw+LqUGPfx2AoVyRk0FLME+GQhufDMyacFmw7ksqw==",
+      "version": "4.7.5",
+      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.7.5.tgz",
+      "integrity": "sha512-DmeAkF6cwM9jSfmp6Dr/5/mfMwb5Z5qRrSXLpo3Fq5SqyU8CMF15jIN4ZhfSwu35ksM1qmHZDQ/DK5XTccSTvA==",
       "dev": true,
       "dependencies": {
         "accepts": "~1.3.4",
@@ -5365,9 +5365,9 @@
       "dev": true
     },
     "socket.io": {
-      "version": "4.7.4",
-      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.7.4.tgz",
-      "integrity": "sha512-DcotgfP1Zg9iP/dH9zvAQcWrE0TtbMVwXmlV4T4mqsvY+gw+LqUGPfx2AoVyRk0FLME+GQhufDMyacFmw7ksqw==",
+      "version": "4.7.5",
+      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.7.5.tgz",
+      "integrity": "sha512-DmeAkF6cwM9jSfmp6Dr/5/mfMwb5Z5qRrSXLpo3Fq5SqyU8CMF15jIN4ZhfSwu35ksM1qmHZDQ/DK5XTccSTvA==",
       "dev": true,
       "requires": {
         "accepts": "~1.3.4",
diff --git a/test/broadcast.ts b/test/broadcast.ts
index e6e45ab..a8041a2 100644
--- a/test/broadcast.ts
+++ b/test/broadcast.ts
@@ -35,10 +35,7 @@ describe("broadcast()", function () {
   });
 
   it("broadcasts to all clients in a namespace", (done) => {
-    const partialDone = times(3, () => {
-      servers.forEach((server) => server.of("/custom").adapter.close());
-      done();
-    });
+    const partialDone = times(3, done);
 
     servers.forEach((server) => server.of("/custom"));
 
diff --git a/test/connection-state-recovery.ts b/test/connection-state-recovery.ts
index 12beab6..ee9eecc 100644
--- a/test/connection-state-recovery.ts
+++ b/test/connection-state-recovery.ts
@@ -21,7 +21,6 @@ describe("connection state recovery", () => {
   });
 
   afterEach(() => {
-    servers[0].of("/foo").adapter.close();
     cleanup();
   });
 
diff --git a/test/util.ts b/test/util.ts
index 4cc7da6..a9a8d2c 100644
--- a/test/util.ts
+++ b/test/util.ts
@@ -149,17 +149,9 @@ export function setup({
               clientSockets,
               ports,
               cleanup: () => {
-                servers.forEach((server) => {
-                  // @ts-ignore
-                  server.httpServer.close();
-                  server.of("/").adapter.close();
-                });
-                clientSockets.forEach((socket) => {
-                  socket.disconnect();
-                });
-                redisClients.forEach((redisClient) => {
-                  redisClient.quit();
-                });
+                servers.forEach((server) => server.close());
+                clientSockets.forEach((socket) => socket.disconnect());
+                redisClients.forEach((redisClient) => redisClient.quit());
               },
             });
           }