Skip to content

processStream

processStream(stream, options): Promise<CollectedStream>

Defined in: streaming.ts:890

Process a stream with callbacks while also returning the collected result.

IRChatStream

ProcessStreamOptions = {}

Promise<CollectedStream>

const result = await processStream(stream, {
onContent: (delta) => process.stdout.write(delta),
onDone: () => console.log('\nDone!'),
});