From cac22bec5ca72c5feaa774d335c9aaba7ee12f6f Mon Sep 17 00:00:00 2001 From: Lizzy Fleckenstein Date: Thu, 9 Feb 2023 16:48:26 +0100 Subject: Get rid of Cell usage --- src/recv.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/recv.rs') diff --git a/src/recv.rs b/src/recv.rs index e685c9c..a88426f 100644 --- 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 RecvWorker { .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 RecvWorker { println!("Rel"); let seqnum = cursor.read_u16::()?; - 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)?; -- cgit v1.2.3