Method #normalResubscribe

packages/client/lib/client/pub-sub.ts:352–364

(commands: PubSubCommand[], type: string, listeners: PubSubTypeListeners)

  }

  #normalResubscribe(commands: PubSubCommand[], type: string, listeners: PubSubTypeListeners) {
    this.#subscribing++;
    const callback = () => this.#subscribing--;
    commands.push({
      args: [
        COMMANDS[type as PubSubType].subscribe,
        ...listeners.keys()
      ],
      channelsCounter: listeners.size,
      resolve: callback,
      reject: callback
    });
  }

  #shardedResubscribe(commands: PubSubCommand[], listeners: PubSubTypeListeners) {
    const callback = () => this.#subscribing--;