We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 203fdc6 commit 0d5adceCopy full SHA for 0d5adce
src/mongoPatch.ts
@@ -28,21 +28,23 @@ export function useProxyForMongo(config: Config) {
28
};
29
return {
30
close: async () => {
31
- console.log(`Closing ${sockets.length} open proxy sockets`);
+ let count = 0;
32
await Promise.all(
33
sockets.map(
34
(socket) =>
35
new Promise<void>((resolve) => {
36
- socket.once('close', ()=>{
37
- console.log('Socket closed');
+ socket.once('close', () => {
+ count++;
38
resolve();
39
});
40
socket.destroy();
41
}),
42
),
43
);
44
- sockets.length = 0;
45
- socks.SocksClient.createConnection = originalCreateConnection;
+ if (count === sockets.length) {
+ console.log(`Closed ${sockets.length} MongoDB connection sockets`);
46
+ process.exit(0);
47
+ }
48
},
49
50
}
0 commit comments