finish receiver

[mt_rudp.git] / src / recv_worker.rs

diff --git a/src/recv_worker.rs b/src/recv_worker.rs
index f83e8efb7dca69ec722723f3f85ef130f94f57de..316bb48e59f19e229d28341b47f551b50e222d0e 100644 (file)
--- a/src/recv_worker.rs
+++ b/src/recv_worker.rs
@@ -133,7 +133,10 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> {
 
         match cursor.read_u8()?.try_into()? {
             PktType::Ctl => match cursor.read_u8()?.try_into()? {
-                CtlType::Ack => { /* TODO */ }
+                CtlType::Ack => {
+                    let seqnum = cursor.read_u16::<BigEndian>()?;
+                    self.share.ack_chans.lock().await.remove(&seqnum);
+                }
                 CtlType::SetPeerID => {
                     let mut id = self.share.remote_id.write().await;