Class StreamBuilder

constructor

• new StreamBuilder(
      outStream: Writable,
      finishFunc?: FinishCallback | null,
  ): StreamBuilder

  Parameters

  • outStream: Writable
  • finishFunc: FinishCallback | null = null

  Returns StreamBuilder

nextSegmentIndex

addBlock

• addBlock(): void

  出力チェーンの末尾に新しいフラグメント (ブロック) を追加する。 追加されたブロックの ID は frgs 配列のインデックスで管理される。

  Returns void

closeBlock

• closeBlock(_id: number): void

  指定ブロックを閉じる。 StreamBuilder では使用しないため何も行わない。

  Parameters

  • _id: number

    閉じるブロックの ID (未使用)

  Returns void

dispose

• dispose(): Promise<void>

  フラグメント配列と一時ファイルを解放する。 エラー発生時にもリソースリークが発生しないよう必ず呼び出すこと。

  Returns Promise<void>

finish

• finish(): Promise<void>

  すべてのフラグメントを順番に出力ストリームへフラッシュする。 finishFunc が設定されている場合は先に呼び出す。 処理後は一時ファイルを削除してリソースを解放する。

  Returns Promise<void>

insertBlockBefore

• insertBlockBefore(anchorId: number): void

  指定した既存ブロックの直前に新しいフラグメントを挿入する。 双方向リンクリストのポインタを更新してフラグメント順序を調整する。

  Parameters

  • anchorId: number

    挿入基準となる既存ブロックの ID

  Returns void

readFromTempFile

• readFromTempFile(buffer: Buffer, position: number): Promise<number>

  一時ファイルの指定位置からデータを読み込む。 一時ファイルが未作成の場合は 0 を返す。

  Parameters

  • buffer: Buffer

    読み込んだデータを格納するバッファ

  • position: number

    ファイル内の読み込み開始バイト位置

  Returns Promise<number>

  実際に読み込んだバイト数

serialWrite

• serialWrite(data: Buffer): Promise<void>

  データをフラグメント管理を介さず出力ストリームへ直接書き込む。 ストリームのバックプレッシャーを考慮して drain イベントを待機する。

  Parameters

  • data: Buffer

    書き込むバイナリデータ

  Returns Promise<void>

write

• write(id: number, data: Buffer): Promise<void>

  指定 ID のフラグメントにデータを書き込む。 フラグメントのメモリ使用量に応じて、自動的にディスクへスピルアウトする。

  Parameters

  • id: number

    書き込み先フラグメントの ID

  • data: Buffer

    書き込むバイナリデータ

  Returns Promise<void>

writeToTempFile

• writeToTempFile(buffer: Buffer, position: number): Promise<void>

  一時ファイルの指定位置にバッファを書き込む。 ファイルが存在しない場合は自動的に作成される。 Fragment クラスがディスクへのスピルアウト時に内部から呼び出す。

  Parameters

  • buffer: Buffer

    書き込むデータ

  • position: number

    ファイル内の書き込み開始バイト位置

  Returns Promise<void>