| 66 | const sockets = new Set() |
| 67 | |
| 68 | function waitForIdle (timeout = 5000) { |
| 69 | if (sockets.size === 0) { |
| 70 | return Promise.resolve() |
| 71 | } |
| 72 | |
| 73 | return new Promise((resolve, reject) => { |
| 74 | const timer = setTimeout(() => { |
| 75 | reject(new Error('Timed out waiting for telnet sockets to close')) |
| 76 | }, timeout) |
| 77 | |
| 78 | const interval = setInterval(() => { |
| 79 | if (sockets.size === 0) { |
| 80 | clearTimeout(timer) |
| 81 | clearInterval(interval) |
| 82 | resolve() |
| 83 | } |
| 84 | }, 25) |
| 85 | }) |
| 86 | } |
| 87 | |
| 88 | const server = net.createServer((socket) => { |
| 89 | sockets.add(socket) |