Method monitor

packages/client/lib/client/commands-queue.ts:475–506

(callback: MonitorCallback, options?: CommandOptions)

  }

  monitor(callback: MonitorCallback, options?: CommandOptions) {
    return new Promise<void>((resolve, reject) => {
      const typeMapping = options?.typeMapping ?? {};
      this.#toWrite.add(
        {
          args: ["MONITOR"],
          chainId: options?.chainId,
          abort: undefined,
          timeout: undefined,
          // using `resolve` instead of using `.then`/`await` to make sure it'll be called before processing the next reply
          resolve: () => {
            // after running `MONITOR` only `MONITOR` and `RESET` replies are expected
            // any other command should cause an error

            // if `RESET` already overrides `onReply`, set monitor as it's fallback
            if (this.#resetFallbackOnReply) {
              this.#resetFallbackOnReply = callback;
            } else {
              this.decoder.onReply = callback;
            }

            this.decoder.getTypeMapping = () => typeMapping;
            resolve();
          },
          reject,
          channelsCounter: undefined,
          typeMapping,
        },
        options?.asap,
      );
    });
  }

  resetDecoder() {
    this.#resetDecoderCallbacks();