Class SyncMemoryWriter

samples/util.ts:92–130

}

export class SyncMemoryWriter implements SyncWriter {
  private chunks: Uint8Array[] = [];
  private _closed = false;
  private _byteCount = 0;
  private enc = new TextEncoder();

  get desiredSize(): number | null {
    return this._closed ? null : 100;
  }

  write(chunk: Uint8Array | string): boolean {
    if (this._closed) throw new Error('Writer is closed');
    const bytes = typeof chunk === 'string' ? this.enc.encode(chunk) : chunk;
    this.chunks.push(bytes);
    this._byteCount += bytes.byteLength;
    return true;
  }

  writev(chunks: (Uint8Array | string)[]): boolean {
    for (const chunk of chunks) {
      this.write(chunk);
    }
    return true;
  }

  end(): number {
    this._closed = true;
    return this._byteCount;
  }

  fail(reason?: any): void {
    this._closed = true;
  }

  getText(): string {
    const dec = new TextDecoder();
    return this.chunks.map((c) => dec.decode(c, { stream: true })).join('') + dec.decode();
  }
}