From 7addfb5aa379a43ab1e88c32f1f1eded77bf92ef Mon Sep 17 00:00:00 2001
From: evgeny <evgeny@adaptto.ru>
Date: Mon, 12 Oct 2026 22:15:11 +0200
Subject: [PATCH] Keep live decoding low latency and preserve publisher stop
 controls

---
 .../app/src/main/java/com/utun/chat/ui/screens/StreamScreen.kt  | 2 ++
 tools/chatgui/CMakeLists.txt                                    | 2 +-
 tools/chatgui/src/streamplayer_window.cpp                       | 1 +
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/tools/chatgui-android/app/src/main/java/com/utun/chat/ui/screens/StreamScreen.kt b/tools/chatgui-android/app/src/main/java/com/utun/chat/ui/screens/StreamScreen.kt
index 3e22c3e6..28837a4e 100644
--- a/tools/chatgui-android/app/src/main/java/com/utun/chat/ui/screens/StreamScreen.kt
+++ b/tools/chatgui-android/app/src/main/java/com/utun/chat/ui/screens/StreamScreen.kt
@@ -82,6 +82,8 @@ fun StreamScreen(channelId: String, channelName: String, sources: List<StreamSou
                     key(group, selected.id, selected.epoch) { LiveStreamView(group, selected.id, selected.epoch, selected.self) }
                 }
                 TextButton(onClick = { onSelect(null); onBack() }) { Text(stringResource(R.string.stream_close_view)) }
+                if (selected.self && local?.ongoing == true) Button(onClick = StreamController::stop,
+                    enabled = local.phase != StreamPhase.STOPPING) { Text(stringResource(R.string.stream_stop)) }
                 return@Column
             }
             if (local?.ongoing == true) {
diff --git a/tools/chatgui/CMakeLists.txt b/tools/chatgui/CMakeLists.txt
index 65c556cb..0efa4722 100644
--- a/tools/chatgui/CMakeLists.txt
+++ b/tools/chatgui/CMakeLists.txt
@@ -437,7 +437,7 @@ target_link_libraries(test_radio_member_mute PRIVATE ${QT_CORE} utun_voice utun
 add_test(NAME test_radio_member_mute COMMAND test_radio_member_mute)
 set(RADIO_MEMBER_TEST_SOURCES src/memberlistmodel.cpp src/avatars/avatarcache.cpp src/avatars/avatarmanager.cpp
     src/avatars/avatarcrop.cpp src/avatars/avatargallery.cpp src/imageviewer_window.cpp db/db_manager.cpp)
-add_executable(test_radio_mute_bridge tests/test_radio_mute_bridge.cpp transport/utun_node.cpp transport/gui_bridge_impl.cpp
+add_executable(test_radio_mute_bridge tests/test_radio_mute_bridge.cpp transport/utun_node.cpp transport/gui_bridge_impl.cpp transport/stream_bridge.cpp
     src/accountdelegate.cpp src/flagpainter.cpp ${RADIO_MEMBER_TEST_SOURCES})
 target_include_directories(test_radio_mute_bridge PRIVATE ${UTUN_INCLUDE_DIRS})
 target_link_libraries(test_radio_mute_bridge PRIVATE ${QT_LIBS} ${QT_TEST_LIB} utun_voice utun pthread)
diff --git a/tools/chatgui/src/streamplayer_window.cpp b/tools/chatgui/src/streamplayer_window.cpp
index 4a3df57d..fb46ac55 100644
--- a/tools/chatgui/src/streamplayer_window.cpp
+++ b/tools/chatgui/src/streamplayer_window.cpp
@@ -243,6 +243,7 @@ void StreamPlayerWindow::decode() {
         if (!decoder) {
             const AVCodec* codec = avcodec_find_decoder(AV_CODEC_ID_H264);
             decoder = codec ? avcodec_alloc_context3(codec) : nullptr;
+            if (decoder) { decoder->thread_count = 1; decoder->flags |= AV_CODEC_FLAG_LOW_DELAY; }
             if (!decoder || avcodec_open2(decoder, codec, nullptr) < 0) { fail(text("Stream video decoder failed")); break; }
             decoder->pkt_timebase = AVRational{1, 1000000};
             waitKey = false;