Barge-in

async with client.tts.streaming_session(voice_id=1071) as session:
    async for chunk in session.send("This is a very long answer that the user "):
        play_audio(chunk.audio)

    # VAD detected the user speaking over the agent — barge in:
    await session.cancel_current()

    # Socket is still open — start the next turn right away:
    async for chunk in session.send("Sure, what would you like instead?", flush=True):
        play_audio(chunk.audio)

const session = client.tts.streamingSession(
  { voiceId: 1071 },
  {
    onChunk: (chunk) => playAudio(chunk.audio),
    onInterrupted: () => stopLocalPlayback(),
  }
);
await session.connect();

session.send('This is a very long answer that the user ');

// VAD detected the user speaking over the agent — barge in:
await session.cancelCurrent();

// Socket is still open — start the next turn right away:
session.send('Sure, what would you like instead?', true);

StreamCallbacks callbacks = new StreamCallbacks() {
    @Override public void onChunk(AudioChunk chunk) { playAudio(chunk); }
    @Override public void onInterrupted() { stopLocalPlayback(); }
};
StreamConfig config = StreamConfig.builder().voiceId(1071).build();

try (StreamingSession session = client.streamingSession(config, callbacks)) {
    session.send("This is a very long answer that the user ");

    // VAD detected the user speaking over the agent — barge in:
    session.cancelCurrent();

    // Socket is still open — start the next turn right away:
    session.send("Sure, what would you like instead?", true);
}

# Mid-turn, the user speaks over the agent:
await ws.send(json.dumps({"cancel": True}))

# Discard any in-flight audio frames until the ack arrives:
async for message in ws:
    data = json.loads(message)
    if data.get("interrupted"):
        break

# The session is fresh — send the next turn on the same connection:
await ws.send(json.dumps({
    "voice_id": 1071,
    "text": "Sure, what would you like instead?",
    "flush": True,
}))