diff --git a/package.json b/package.json
index 5155bd4e..17847dd7 100644
--- a/package.json
+++ b/package.json
@@ -1,7 +1,7 @@
 {
     "name": "@d-id/client-sdk",
     "private": false,
-    "version": "1.1.28",
+    "version": "1.1.29",
     "type": "module",
     "description": "d-id client sdk",
     "repository": {
diff --git a/src/services/streaming-manager/livekit-manager.ts b/src/services/streaming-manager/livekit-manager.ts
index 4cf7e5bc..bd167c55 100644
--- a/src/services/streaming-manager/livekit-manager.ts
+++ b/src/services/streaming-manager/livekit-manager.ts
@@ -27,6 +27,7 @@ import type {
     RoomEvent,
     SubscriptionError,
     Track,
+    TranscriptionSegment,
 } from 'livekit-client';
 
 async function importLiveKit(): Promise<{
@@ -142,11 +143,18 @@ export async function createLiveKitStreamingManager<T extends CreateSessionV2Opt
         .on(RoomEvent.TrackUnsubscribed, handleTrackUnsubscribed)
         .on(RoomEvent.DataReceived, handleDataReceived)
         .on(RoomEvent.MediaDevicesError, handleMediaDevicesError)
+        .on(RoomEvent.TranscriptionReceived, handleTranscriptionReceived)
         .on(RoomEvent.EncryptionError, handleEncryptionError)
         .on(RoomEvent.TrackSubscriptionFailed, handleTrackSubscriptionFailed);
 
     callbacks.onConnectionStateChange?.(ConnectionState.New);
 
+    function handleTranscriptionReceived(_segments: TranscriptionSegment[], participant?: Participant): void {
+        if (participant?.isLocal && currentActivityState === AgentActivityState.Talking) {
+            callbacks.onInterruptDetected?.({ type: 'audio' });
+            currentActivityState = AgentActivityState.Idle;
+        }
+    }
     try {
         await room.connect(url, token);
         log('LiveKit room joined successfully');
@@ -217,17 +225,9 @@ export async function createLiveKitStreamingManager<T extends CreateSessionV2Opt
 
     function handleActiveSpeakersChanged(activeSpeakers: Participant[]): void {
         log('Active speakers changed:', activeSpeakers);
-        const isLocalParticipantSpeaking = activeSpeakers.find(speaker => speaker.isLocal);
         const isRemoteParticipantSpeaking = activeSpeakers.find(speaker => !speaker.isLocal);
 
-        if (isLocalParticipantSpeaking) {
-            callbacks.onAgentActivityStateChange?.(AgentActivityState.Idle);
-
-            if (currentActivityState !== AgentActivityState.Idle) {
-                callbacks.onInterruptDetected?.({ type: 'audio' });
-                currentActivityState = AgentActivityState.Idle;
-            }
-        } else if (isRemoteParticipantSpeaking) {
+        if (isRemoteParticipantSpeaking) {
             currentActivityState = AgentActivityState.Talking;
             callbacks.onAgentActivityStateChange?.(AgentActivityState.Talking);
         } else {