We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 10bfe59 commit 673e7acCopy full SHA for 673e7ac
1 file changed
src/mongoPatch.ts
@@ -26,12 +26,16 @@ export function useProxyForMongo(config: Config) {
26
return {
27
close: async () => {
28
console.log(`Closing ${sockets.length} open proxy sockets`);
29
- for (const socket of sockets) {
30
- await new Promise((resolve, reject) => {
31
- socket.on('close', () => resolve(null));
32
- socket.end();
33
- });
34
- }
+ await Promise.all(
+ sockets.map(
+ (socket) =>
+ new Promise<void>((resolve) => {
+ socket.once('close', resolve);
+ socket.destroy();
35
+ }),
36
+ ),
37
+ );
38
+ sockets.length = 0;
39
},
40
};
41
}
0 commit comments