Utf8StreamDecoder

export class Utf8StreamDecoder implements StreamDecoder {
  readonly id = "utf8";
  readonly #decoder = new TextDecoder("utf-8", { fatal: false });

  write(chunk: Uint8Array | string): string {
    return typeof chunk === "string"
      ? chunk
      : this.#decoder.decode(chunk, { stream: true });
  }

  flush(): string {
    return this.#decoder.decode();
  }

  reset(): void {
    // TextDecoder has no reset primitive; flushing establishes a new stream.
    this.#decoder.decode();
  }
}