Function testConcurrentSessions

sdk/node/examples/basic/test_runtime_nesting.ts:105–150

()

// Test with multiple concurrent sessions (stress test)
async function testConcurrentSessions() {
  console.log();
  console.log('='.repeat(70));
  console.log('  Test: Concurrent Sessions (Stress Test)');
  console.log('='.repeat(70));
  console.log();

  const configPath = findConfig();

  try {
    const agent = await Agent.create(configPath);
    console.log('  ✓ Agent created for concurrent test');
    console.log();

    console.log('  Creating 3 concurrent sessions...');
    const sessions = [
      agent.session('.', { builtinSkills: true }),
      agent.session('.', { builtinSkills: true }),
      agent.session('.', { builtinSkills: true }),
    ];
    console.log('  ✓ All sessions created');
    console.log();

    console.log('  Sending concurrent prompts...');
    const results = await Promise.all([
      sessions[0].send('What is 2+2? Answer in numbers only.'),
      sessions[1].send('What is 3+3? Answer in numbers only.'),
      sessions[2].send('What is 4+4? Answer in numbers only.'),
    ]);

    console.log('  ✓ All responses received:');
    results.forEach((r, i) => {
      console.log(`    Session ${i + 1}: ${r.text.substring(0, 50)}`);
    });
    console.log();

    console.log('='.repeat(70));
    console.log('  [PASS] Concurrent sessions work correctly!');
    console.log('='.repeat(70));
    return true;
  } catch (error: any) {
    console.error();
    console.error('  [FAIL] Error:', error.message || error);
    return false;
  }
}

// Main
async function main() {