aboutsummaryrefslogtreecommitdiff
path: root/src/recv.rs
diff options
context:
space:
mode:
authorLizzy Fleckenstein <eliasfleckenstein@web.de>2023-02-15 22:04:42 +0100
committerLizzy Fleckenstein <eliasfleckenstein@web.de>2023-02-15 22:04:42 +0100
commit9498c45d1291c0b2343339bad624d0dc0ca0a934 (patch)
tree5009bdb91b2678b25905800447605b8e289c4efd /src/recv.rs
parent1d4ebed25ff3e05d2fac70a040901fd3ea3029eb (diff)
downloadmt_rudp-9498c45d1291c0b2343339bad624d0dc0ca0a934.tar.xz
Use Cow for Pkt
Diffstat (limited to 'src/recv.rs')
-rw-r--r--src/recv.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/recv.rs b/src/recv.rs
index 572b17e..c87a0fe 100644
--- a/src/recv.rs
+++ b/src/recv.rs
@@ -2,6 +2,7 @@ use super::*;
use async_recursion::async_recursion;
use byteorder::{BigEndian, ReadBytesExt, WriteBytesExt};
use std::{
+ borrow::Cow,
cell::OnceCell,
collections::HashMap,
io,
@@ -114,7 +115,7 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
Pkt {
unrel: true,
chan: 0,
- data: &[CtlType::Disco as u8],
+ data: Cow::Borrowed(&[CtlType::Disco as u8]),
},
)
.await
@@ -210,7 +211,7 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
self.pkt_tx.send(Ok(Pkt {
chan: chan.num,
unrel,
- data: cursor.remaining_slice().into(),
+ data: Cow::Owned(cursor.remaining_slice().into()),
}))?;
}
PktType::Split => {
@@ -273,7 +274,7 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
Pkt {
unrel: true,
chan: chan.num,
- data: &ack_data,
+ data: Cow::Borrowed(&ack_data),
},
)
.await?;