diff options
author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-15 22:04:42 +0100 |
---|---|---|
committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-15 22:04:42 +0100 |
commit | 9498c45d1291c0b2343339bad624d0dc0ca0a934 (patch) | |
tree | 5009bdb91b2678b25905800447605b8e289c4efd /src/recv.rs | |
parent | 1d4ebed25ff3e05d2fac70a040901fd3ea3029eb (diff) | |
download | mt_rudp-9498c45d1291c0b2343339bad624d0dc0ca0a934.tar.xz |
Use Cow for Pkt
Diffstat (limited to 'src/recv.rs')
-rw-r--r-- | src/recv.rs | 7 |
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?; |