Function main

sdk/node/examples/streaming/test_minimax_stream.ts:30–92

()

}

async function main(): Promise<void> {
  const configPath = resolveConfigPath();
  console.log(`Using config: ${configPath}\n`);

  const agent = await Agent.create(configPath);
  const session = agent.session('.', {
    permissionPolicy: { defaultDecision: 'allow' },
    maxToolRounds: 0,
  });

  console.log('Streaming with prompt: "Say hello in 5 words"\n');

  const stream = await session.stream('Say hello in 5 words');

  let eventCount = 0;
  const eventTypes = new Map<string, number>();
  const textDeltas: string[] = [];
  const reasoningDeltas: string[] = [];

  while (true) {
    const result = await stream.next();
    if (!result.value || result.done) break;

    const event = result.value;
    eventCount++;
    const type = event.type || 'unknown';
    const count = eventTypes.get(type) ?? 0;
    eventTypes.set(type, count + 1);

    if (type === 'text_delta' && event.text) {
      textDeltas.push(event.text);
    } else if (type === 'reasoning_delta' && event.text) {
      reasoningDeltas.push(event.text);
    }

    // Log first 10 events
    if (eventCount <= 10) {
      console.log(
        `[${eventCount}] type="${type}"` +
          (event.text ? ` text="${event.text.slice(0, 40)}"` : '') +
          (event.data ? ` data="${event.data?.slice(0, 60)}"` : ''),
      );
    }
  }

  console.log('\n' + '='.repeat(80));
  console.log('Summary:');
  console.log(`Total events: ${eventCount}`);
  console.log('Event types received:');
  for (const [type, count] of eventTypes) {
    console.log(`  ${type}: ${count}`);
  }
  console.log(`\nTextDelta count: ${textDeltas.length}`);
  console.log(`Text content: "${textDeltas.join('')}"`);
  console.log(`\nReasoningDelta count: ${reasoningDeltas.length}`);
  console.log(`Reasoning content preview: "${reasoningDeltas.slice(0, 3).join('').slice(0, 100)}..."`);

  if (reasoningDeltas.length > 0 && textDeltas.join('').length === 0) {