fix(android): stabilize realtime talk connection state

obviyus · obviyus · commit ffb02a59199f · 2026-05-25T09:01:07.000+05:30
diff --git a/apps/android/app/src/main/java/ai/openclaw/app/NodeRuntime.kt b/apps/android/app/src/main/java/ai/openclaw/app/NodeRuntime.kt
@@ -515,7 +515,7 @@ class NodeRuntime(
         context = appContext,
         scope = scope,
         session = operatorSession,
-        isConnected = { operatorConnected },
+        isConnected = { _isConnected.value },
         onBeforeSpeak = { micCapture.pauseForTts() },
         onAfterSpeak = { micCapture.resumeAfterTts() },
       ).also { speaker ->
@@ -622,7 +622,7 @@ class NodeRuntime(
       context = appContext,
       scope = scope,
       session = operatorSession,
-      isConnected = { operatorConnected },
+      isConnected = { _isConnected.value },
       onBeforeSpeak = { micCapture.pauseForTts() },
       onAfterSpeak = { micCapture.resumeAfterTts() },
       onStoppedByRelay = { finishTalkModeAfterRelayClose() },
diff --git a/apps/android/app/src/main/java/ai/openclaw/app/voice/TalkModeManager.kt b/apps/android/app/src/main/java/ai/openclaw/app/voice/TalkModeManager.kt
@@ -578,7 +578,7 @@ class TalkModeManager internal constructor(
       while (true) {
         realtimeSessionId?.let { return@withTimeout it }
         val status = _statusText.value
-        if (!_isEnabled.value && status.startsWith("Talk failed")) {
+        if (!_isEnabled.value && status != "Off") {
           throw IllegalStateException(status)
         }
         delay(100L)

Original file line number	Diff line number	Diff line change
`@@ -578,7 +578,7 @@ class TalkModeManager internal constructor(`
`578`	`578`	`while (true) {`
`579`	`579`	`realtimeSessionId?.let { return@withTimeout it }`
`580`	`580`	`val status = _statusText.value`
`581`		`- if (!_isEnabled.value && status.startsWith("Talk failed")) {`
	`581`	`+ if (!_isEnabled.value && status != "Off") {`
`582`	`582`	`throw IllegalStateException(status)`
`583`	`583`	`}`
`584`	`584`	`delay(100L)`