Get rid of Cell usage

[mt_rudp.git] / src / recv.rs

diff --git a/src/recv.rs b/src/recv.rs
index e685c9c518e58058b63ad20313e14b82fadabdc2..a88426f847c4a4f650d1ad428461bb458f063dec 100644 (file)
--- a/src/recv.rs
+++ b/src/recv.rs
@@ -2,7 +2,7 @@ use crate::{prelude::*, ticker, RecvChan, RecvWorker, RudpShare, Split};
 use async_recursion::async_recursion;
 use byteorder::{BigEndian, ReadBytesExt, WriteBytesExt};
 use std::{
-    cell::{Cell, OnceCell},
+    cell::OnceCell,
     collections::HashMap,
     io,
     pin::Pin,
@@ -34,7 +34,7 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
                     .map(|num| {
                         Mutex::new(RecvChan {
                             num,
-                            packets: (0..REL_BUFFER).map(|_| Cell::new(None)).collect(),
+                            packets: (0..REL_BUFFER).map(|_| None).collect(),
                             seqnum: INIT_SEQNUM,
                             splits: HashMap::new(),
                         })
@@ -239,7 +239,7 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
                 println!("Rel");
 
                 let seqnum = cursor.read_u16::<BigEndian>()?;
-                chan.packets[to_seqnum(seqnum)].set(Some(cursor.remaining_slice().into()));
+                chan.packets[to_seqnum(seqnum)].replace(cursor.remaining_slice().into());
 
                 let mut ack_data = Vec::with_capacity(3);
                 ack_data.write_u8(CtlType::Ack as u8)?;