Function recordTerminalWriteStats

src/ink/terminalWriteStats.ts:68–110

(params: {
  inputPatchTypes: ReadonlyArray<TerminalPatchType>
  serializedBytes: number
  useSync: boolean
  serializeDurationMs: number
  stdoutPatchBytes: number
  stdoutPatchCount: number
})

}

export function recordTerminalWriteStats(params: {
  inputPatchTypes: ReadonlyArray<TerminalPatchType>
  serializedBytes: number
  useSync: boolean
  serializeDurationMs: number
  stdoutPatchBytes: number
  stdoutPatchCount: number
}): void {
  const nextCounts = { ...stats.patchTypeCounts }
  for (const type of params.inputPatchTypes) {
    nextCounts[type] += 1
  }
  stats = {
    ...stats,
    writeCalls: stats.writeCalls + 1,
    totalInputPatches: stats.totalInputPatches + params.inputPatchTypes.length,
    maxInputPatchCount: Math.max(
      stats.maxInputPatchCount,
      params.inputPatchTypes.length,
    ),
    patchTypeCounts: nextCounts,
    syncWrappedCalls: stats.syncWrappedCalls + (params.useSync ? 1 : 0),
    totalSerializedBytes: stats.totalSerializedBytes + params.serializedBytes,
    maxSerializedBytes: Math.max(stats.maxSerializedBytes, params.serializedBytes),
    totalStdoutPatchBytes: stats.totalStdoutPatchBytes + params.stdoutPatchBytes,
    maxStdoutPatchBytes: Math.max(
      stats.maxStdoutPatchBytes,
      params.stdoutPatchBytes,
    ),
    lastStdoutPatchBytes: params.stdoutPatchBytes,
    lastStdoutPatchCount: params.stdoutPatchCount,
    totalSerializeDurationMs:
      stats.totalSerializeDurationMs + params.serializeDurationMs,
    maxSerializeDurationMs: Math.max(
      stats.maxSerializeDurationMs,
      params.serializeDurationMs,
    ),
    lastSerializeDurationMs: params.serializeDurationMs,
    lastSerializedBytes: params.serializedBytes,
    lastInputPatchCount: params.inputPatchTypes.length,
    lastUseSync: params.useSync,
  }
}

export function getTerminalWriteStatsSnapshot(): TerminalWriteStatsSnapshot {
  return {