Function main

examples/nodejs/examples/pipe.run.stream.ts:7–39

()

const pipe = new Pipe(pipeSummary());

async function main() {
	const userMsg = 'Who is an AI Engineer?';

	// Get readable stream
	const {stream, threadId, rawResponse} = await pipe.run({
		messages: [{role: 'user', content: userMsg}],
		stream: true,
		rawResponse: true,
	});

	// Convert the stream to a stream runner.
	const runner = getRunner(stream);

	// Method 1: Using event listeners
	runner.on('connect', () => {
		console.log('Stream started.\n');
	});

	runner.on('content', content => {
		process.stdout.write(content);
	});

	runner.on('end', () => {
		console.log('\nStream ended.');
	});

	runner.on('error', error => {
		console.error('Error:', error);
	});

	// Method 2: Using `for await of` loop
	// Check the `pipe.run.stream.loop.ts` example for this method
}

main();