Function mergeTerminalChunks

frontend/src/hooks/useTerminalStream.ts:28–49

(
  existing: TerminalChunk[],
  incoming: TerminalChunk[],
  options: { max?: number } = {},
)

}

export function mergeTerminalChunks(
  existing: TerminalChunk[],
  incoming: TerminalChunk[],
  options: { max?: number } = {},
): TerminalChunk[] {
  if (incoming.length === 0) {
    return existing;
  }
  const maxSize = options.max ?? MAX_BUFFER;
  const map = new Map<number, TerminalChunk>();
  for (const chunk of existing) {
    map.set(chunk.chunkIndex, chunk);
  }
  for (const chunk of incoming) {
    map.set(chunk.chunkIndex, chunk);
  }
  const merged = Array.from(map.values()).sort((a, b) => a.chunkIndex - b.chunkIndex);
  if (merged.length > maxSize) {
    return merged.slice(merged.length - maxSize);
  }
  return merged;
}

export function useTerminalStream(options: UseTerminalStreamOptions): UseTerminalStreamResult {
  const { runId, nodeId, stream = 'pty', autoConnect = true } = options;