Method reset

packages/client/lib/client/commands-queue.ts:515–546

(chainId: symbol, typeMapping?: T)

  #resetFallbackOnReply?: Decoder["onReply"];

  async reset<T extends TypeMapping>(chainId: symbol, typeMapping?: T) {
    return new Promise((resolve, reject) => {
      // overriding onReply to handle `RESET` while in `MONITOR` or PubSub mode
      this.#resetFallbackOnReply = this.decoder.onReply;
      this.decoder.onReply = ((reply) => {
        if (
          (typeof reply === "string" && reply === "RESET") ||
          (reply instanceof Buffer && RESET.equals(reply))
        ) {
          this.#resetDecoderCallbacks();
          this.#resetFallbackOnReply = undefined;
          this.#pubSub.reset();

          this.#waitingForReply.shift()!.resolve(reply);
          return;
        }

        this.#resetFallbackOnReply!(reply);
      }) as Decoder["onReply"];

      this.#toWrite.push({
        args: ["RESET"],
        chainId,
        abort: undefined,
        timeout: undefined,
        resolve,
        reject,
        channelsCounter: undefined,
        typeMapping,
      });
    });
  }

  isWaitingToWrite() {
    return this.#toWrite.length > 0;