fix:补充echo测试代码
This commit is contained in:
parent
6147b86e8b
commit
8e6b1a047b
File diff suppressed because one or more lines are too long
@ -260,7 +260,8 @@ class ScpMessage {
|
|||||||
} else {
|
} else {
|
||||||
throw FormatException("Invalid PayloadLength length");
|
throw FormatException("Invalid PayloadLength length");
|
||||||
}
|
}
|
||||||
// print("message result: $message");
|
print(
|
||||||
|
"======================messageId: ${message.MessageId}, spTotal: ${message.SpTotal}, spIndex: ${message.SpIndex}, payloadType: ${message.PayloadType}, payloadLength: ${message.PayloadLength}");
|
||||||
|
|
||||||
// 处理其他类型的Payload
|
// 处理其他类型的Payload
|
||||||
if (message.PayloadLength != null &&
|
if (message.PayloadLength != null &&
|
||||||
@ -526,8 +527,6 @@ class ScpMessage {
|
|||||||
required List<int> byte,
|
required List<int> byte,
|
||||||
required int payloadType,
|
required int payloadType,
|
||||||
}) {
|
}) {
|
||||||
// print(
|
|
||||||
// '_handleFragmentedPayload spTotal:$spTotal spindex:$spIndex} byte:${byte.take(20)}');
|
|
||||||
// 初始化分包列表
|
// 初始化分包列表
|
||||||
if (!_packetBuffer.containsKey(messageId)) {
|
if (!_packetBuffer.containsKey(messageId)) {
|
||||||
_packetBuffer[messageId] = List.filled(spTotal, []);
|
_packetBuffer[messageId] = List.filled(spTotal, []);
|
||||||
@ -549,13 +548,10 @@ class ScpMessage {
|
|||||||
// 解析完整的 payload
|
// 解析完整的 payload
|
||||||
final TalkData talkData = TalkData.fromBuffer(completePayload);
|
final TalkData talkData = TalkData.fromBuffer(completePayload);
|
||||||
return talkData;
|
return talkData;
|
||||||
|
} else {
|
||||||
|
String payload = utf8.decode(completePayload);
|
||||||
|
return payload;
|
||||||
}
|
}
|
||||||
|
|
||||||
return completePayload;
|
|
||||||
|
|
||||||
// 解析完整的 payload
|
|
||||||
// final TalkData talkData = TalkData.fromBuffer(completePayload);
|
|
||||||
// String payload = utf8.decode(completePayload);
|
|
||||||
} else {
|
} else {
|
||||||
// 如果分包尚未接收完全,返回 null 或其他指示符
|
// 如果分包尚未接收完全,返回 null 或其他指示符
|
||||||
return null;
|
return null;
|
||||||
|
|||||||
@ -19,10 +19,11 @@ class UdpEchoTestHandler extends ScpMessageBaseHandle
|
|||||||
// TODO: 收到回声测试回复
|
// TODO: 收到回声测试回复
|
||||||
final List<int> payload = scpMessage.Payload;
|
final List<int> payload = scpMessage.Payload;
|
||||||
|
|
||||||
talkDataRepository.addTalkData(
|
|
||||||
TalkData(content: payload, contentType: TalkData_ContentTypeE.Image));
|
|
||||||
if (payload is String) {
|
if (payload is String) {
|
||||||
EasyLoading.showToast(scpMessage.Payload, duration: 2000.milliseconds);
|
EasyLoading.showToast(scpMessage.Payload, duration: 2000.milliseconds);
|
||||||
|
} else {
|
||||||
|
talkDataRepository.addTalkData(
|
||||||
|
TalkData(content: payload, contentType: TalkData_ContentTypeE.Image));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user