Function init

packages/socket.io-redis-streams-emitter/test/util.ts:102–136

()

}

async function init() {
  const redisClient = await initRedisClient();

  const httpServer = createServer();
  const io = new Server(httpServer, {
    adapter: createAdapter(redisClient, {
      readCount: 1, // return as soon as possible
    }),
  });

  return new Promise<{
    io: Server;
    socket: ServerSocket;
    clientSocket: ClientSocket;
    cleanup: () => void;
  }>((resolve) => {
    httpServer.listen(() => {
      const port = (httpServer.address() as AddressInfo).port;
      const clientSocket = ioc(`http://localhost:${port}`);

      io.on("connection", async (socket) => {
        resolve({
          io,
          socket,
          clientSocket,
          cleanup: () => {
            io.close();
            clientSocket.disconnect();
            redisClient.quit();
          },
        });
      });
    });
  });
}

export async function setup() {
  const results = await Promise.all([init(), init(), init()]);