Method subscribe

packages/client/lib/client/commands-queue.ts:376–392

(
    type: PubSubType,
    channels: string | Array<string>,
    listener: PubSubListener<T>,
    returnBuffers?: T,
  )

  }

  subscribe<T extends boolean>(
    type: PubSubType,
    channels: string | Array<string>,
    listener: PubSubListener<T>,
    returnBuffers?: T,
  ) {
    const command = this.#pubSub.subscribe(
      type,
      channels,
      listener,
      returnBuffers,
    );
    if (!command) return;

    this.#setupPubSubHandler();
    return this.#addPubSubCommand(command);
  }

  #resetDecoderCallbacks() {
    this.decoder.onReply = ((reply) =>