Function processTextChunk

cli/src/utils/stream-chunk-processor.ts:40–57

(
  blocks: ContentBlock[],
  destination: ChunkDestination,
  text: string,
)

}

export const processTextChunk = (
  blocks: ContentBlock[],
  destination: ChunkDestination,
  text: string,
): ContentBlock[] => {
  if (!text) {
    return blocks
  }

  if (destination.type === 'agent') {
    return appendTextToAgentBlock(blocks, destination.agentId, text, destination.textType)
  }

  return appendTextToRootStream(blocks, {
    type: destination.textType,
    text,
  })
}