style(android): fix voice ktlint formatting · openclaw/openclaw@d204ec0
obviyus
·
2026-05-18
·
via Recent Commits to openclaw:main
File tree
main/java/ai/openclaw/app
test/java/ai/openclaw/app/voice
| Original file line number | Diff line number | Diff line change |
|---|
@@ -1166,8 +1166,10 @@ internal fun shouldPauseGatewayReconnectAfterAuthFailure(
|
1166 | 1166 | role?.trim() == "node" && |
1167 | 1167 | scopes.isEmpty() && |
1168 | 1168 | error.details.reason == "not-paired" && |
1169 | | - (error.details.pauseReconnect == false || |
1170 | | - error.details.recommendedNextStep == "wait_then_retry") |
| 1169 | + ( |
| 1170 | + error.details.pauseReconnect == false || |
| 1171 | + error.details.recommendedNextStep == "wait_then_retry" |
| 1172 | + ) |
1171 | 1173 | ) |
1172 | 1174 | "AUTH_TOKEN_MISMATCH" -> deviceTokenRetryBudgetUsed && !pendingDeviceTokenRetry |
1173 | 1175 | else -> false |
|
| Original file line number | Diff line number | Diff line change |
|---|
@@ -759,10 +759,10 @@ class MicCaptureManager(
|
759 | 759 | var outputIndex = 0 |
760 | 760 | while (inputIndex + 1 < pcm16.size) { |
761 | 761 | val sample = |
762 | | - ((pcm16[inputIndex].toInt() and 0xff) or |
763 | | - (pcm16[inputIndex + 1].toInt() shl 8)) |
764 | | -.toShort() |
765 | | - .toInt() |
| 762 | + ( |
| 763 | + (pcm16[inputIndex].toInt() and 0xff) or |
| 764 | + (pcm16[inputIndex + 1].toInt() shl 8) |
| 765 | +).toShort().toInt() |
766 | 766 | output[outputIndex] = linear16ToPcmu(sample) |
767 | 767 | inputIndex += 2 |
768 | 768 | outputIndex += 1 |
|
| Original file line number | Diff line number | Diff line change |
|---|
@@ -169,11 +169,15 @@ class TalkModeManager internal constructor(
|
169 | 169 | private val realtimePlaybackLock = Any() |
170 | 170 | private var realtimeAudioTrack: AudioTrack? = null |
171 | 171 | private var realtimePlaybackIdleJob: Job? = null |
172 | | - @Volatile private var realtimePlaybackEndsAtMs = 0L |
173 | 172 | |
174 | | - @Volatile private var realtimeOutputSuppressed = false |
| 173 | + @Volatile |
| 174 | +private var realtimePlaybackEndsAtMs = 0L |
175 | 175 | |
176 | | - @Volatile private var playbackEnabled = true |
| 176 | + @Volatile |
| 177 | +private var realtimeOutputSuppressed = false |
| 178 | + |
| 179 | + @Volatile |
| 180 | +private var playbackEnabled = true |
177 | 181 | private val playbackGeneration = AtomicLong(0L) |
178 | 182 | |
179 | 183 | private var ttsJob: Job? = null |
@@ -755,11 +759,9 @@ class TalkModeManager internal constructor(
|
755 | 759 | } |
756 | 760 | } |
757 | 761 | |
758 | | -private fun shouldAppendRealtimeCapturedFrame(length: Int): Boolean = |
759 | | -!isRealtimePlaybackActive() && length > 0 |
| 762 | +private fun shouldAppendRealtimeCapturedFrame(length: Int): Boolean = !isRealtimePlaybackActive() && length > 0 |
760 | 763 | |
761 | | -private fun isRealtimePlaybackActive(): Boolean = |
762 | | -_isSpeaking.value || SystemClock.elapsedRealtime() < realtimePlaybackEndsAtMs |
| 764 | +private fun isRealtimePlaybackActive(): Boolean = _isSpeaking.value || SystemClock.elapsedRealtime() < realtimePlaybackEndsAtMs |
763 | 765 | |
764 | 766 | private fun handleRealtimeTalkEvent(payloadJson: String?) { |
765 | 767 | if (payloadJson.isNullOrBlank()) return |
|
| Original file line number | Diff line number | Diff line change |
|---|
@@ -151,7 +151,12 @@ class MicCaptureManagerTest {
|
151 | 151 | ) |
152 | 152 | runCurrent() |
153 | 153 | |
154 | | - assertEquals("testing testing 1 2 3", manager.conversation.value.single().text) |
| 154 | + assertEquals( |
| 155 | +"testing testing 1 2 3", |
| 156 | + manager.conversation.value |
| 157 | + .single() |
| 158 | + .text, |
| 159 | + ) |
155 | 160 | assertEquals("transcription-1", privateField<String?>(manager, "transcriptionSessionId")) |
156 | 161 | privateField<Job?>(manager, "transcriptionDrainJob")?.cancel() |
157 | 162 | } |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。