sky/app-starlock
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style:调整流控制器数据类型

Browse Source
This commit is contained in:
liyi 2024-12-17 09:17:50 +08:00
parent 1bafcd535a
commit fdd4461f90
3 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/talk/startChart/handle/impl/udp_talk_data_handler.dart
View File

@ -53,8 +53,7 @@ class UdpTalkDataHandler extends ScpMessageBaseHandle
/// 处理h264协议的数据
void _handleVideoH264(TalkData talkData) {
final List<int> content = talkData.content;
talkDataRepository.addTalkData(content);
talkDataRepository.addTalkData(talkData);
}
/// 处理图片数据

6
lib/talk/startChart/handle/other/talk_data_repository.dart
View File

@ -13,13 +13,13 @@ class TalkDataRepository {
static TalkDataRepository get instance => _instance;
// 创建一个 StreamController
final StreamController<List<int>> _talkDataStreamController = StreamController<List<int>>.broadcast();
final StreamController<TalkData> _talkDataStreamController = StreamController<TalkData>.broadcast();
// 提供一个方法来获取 Stream
Stream<List<int>> get talkDataStream => _talkDataStreamController.stream;
Stream<TalkData> get talkDataStream => _talkDataStreamController.stream;
// 提供一个方法来添加 TalkData 到 Stream
void addTalkData(List<int> talkData) {
void addTalkData(TalkData talkData) {
_talkDataStreamController.add(talkData);
}

8
lib/talk/startChart/webView/h264_web_view.dart
View File

@ -5,6 +5,7 @@ import 'package:flutter/services.dart' show ByteData, Uint8List, rootBundle;
import 'package:flutter_screenutil/flutter_screenutil.dart';
import 'package:star_lock/app_settings/app_colors.dart';
import 'package:star_lock/talk/startChart/handle/other/talk_data_repository.dart';
import 'package:star_lock/talk/startChart/proto/talk_data.pbserver.dart';
import 'package:star_lock/tools/titleAppBar.dart';
import 'package:webview_flutter/webview_flutter.dart';
@ -70,15 +71,16 @@ class _H264WebViewState extends State<H264WebView> {
current++;
List<int> frameData = byteData.sublist(start, end);
if (frameData.length == 0) timer.cancel();
talkDataRepository.addTalkData(frameData);
talkDataRepository.addTalkData(TalkData(contentType: TalkData_ContentTypeE.H264,content: frameData));
start = end;
});
}
void _sendFramesToHtml() async {
// 接收到流数据，保存到缓冲区
talkDataRepository.talkDataStream.listen((event) async {
_buffer.addAll(event);
talkDataRepository.talkDataStream.listen((TalkData event) async {
_buffer.addAll(event.content);
});
// 缓冲800ms的数据，定时发送
_sendTimer ??= Timer.periodic(