Function emit

packages/socket.io-cluster-engine/lib/engine.ts:640–666

(ev: string, ...args: any[])

  }

  override emit(ev: string, ...args: any[]): boolean {
    if (ev !== "connection") {
      return super.emit(ev, ...args);
    }

    const socket = args[0] as Socket;

    if (socket.transport.name === "websocket") {
      return super.emit(ev, ...args);
    }

    debug("delaying connection");

    socket[kDelayed] = true;
    socket[kBuffer] = [];

    socket[kPacketListener] = (packet: Packet) => {
      socket[kBuffer].push(packet);
    };

    socket.on("packet", socket[kPacketListener]);

    socket[kDelayedTimer] = setTimeout(
      () => this._doConnect(socket),
      this._opts.delayedConnectionTimeout,
    );
  }

  private _doConnect(socket: Socket) {
    if (!socket[kDelayed] || socket.readyState !== "open") {