send heartbeat

Author: darrachequesne

test/util.ts

@@ -38,9 +38,6 @@ function createServerAndClient(pool: Pool, channelPrefix: string) {
     }),
   });
 
-  // calling init() sends an INITIAL_HEARTBEAT message to the other nodes, so each node knows about the others
-  io.of("/").adapter.init();
-
   return new Promise<{
     io: Server;
     socket: ServerSocket;
@@ -103,8 +100,11 @@ export async function setup() {
   const serverSockets = results.map(({ socket }) => socket);
   const clientSockets = results.map(({ clientSocket }) => clientSocket);
 
-  while (!isInitComplete(servers)) {
-    await sleep(20);
+  for (let i = 0; !isInitComplete(servers) && i < 10; i++) {
+    // calling init() sends an INITIAL_HEARTBEAT message to the other nodes, so each node knows about the others
+    servers[0].of("/").adapter.init();
+
+    await sleep(50);
   }
 
   return {