Handle UNPARKING state in Receiver::drop()

CHANGELOG.md

@@ -16,6 +16,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+- Handle the UNPARKING state correctly in `Receiver::drop()`.
+
 
 ## [0.1.10] - 2025-02-04
 ### Added

src/lib.rs

@@ -1050,6 +1050,31 @@ impl<T> Drop for Receiver<T> {
                 // SAFETY: see safety comment at top of function
                 unsafe { dealloc(self.channel_ptr) };
             }
+            // The sender has observed the RECEIVING state and is currently reading the waker from
+            // a poll. We need to loop here until we observe the MESSAGE or DISCONNECTED state.
+            // We busy loop here since we know the sender is done very soon.
+            #[cfg(any(feature = "std", feature = "async"))]
+            UNPARKING => loop {
+                hint::spin_loop();
+                // ORDERING: The load above has already synchronized with the write of the message.
+                match channel.state.load(Relaxed) {
+                    MESSAGE => {
+                        // SAFETY: we are in the message state so the message is initialized
+                        unsafe { channel.drop_message() };
+
+                        // SAFETY: see safety comment at top of function
+                        unsafe { dealloc(self.channel_ptr) };
+                        break;
+                    }
+                    DISCONNECTED => {
+                        // SAFETY: see safety comment at top of function
+                        unsafe { dealloc(self.channel_ptr) };
+                        break;
+                    }
+                    UNPARKING => (),
+                    _ => unreachable!(),
+                }
+            },
             _ => unreachable!(),
         }
     }