(worker)
| 15 | setupPrimary(); |
| 16 | |
| 17 | const getRooms = (worker): Promise<Set<string>> => { |
| 18 | worker.send("get rooms"); |
| 19 | return new Promise((resolve) => { |
| 20 | worker.once("message", (content) => { |
| 21 | resolve(content); |
| 22 | }); |
| 23 | }); |
| 24 | }; |
| 25 | |
| 26 | describe("@socket.io/cluster-adapter", () => { |
| 27 | let clientSockets: ClientSocket[], workers: Worker[]; |