Refactor ManualResetEvent to use PinList

Cargo.toml

@@ -15,13 +15,15 @@ name = "futures_intrusive"
 
 [features]
 alloc = ["futures-core/alloc"]
-std = ["alloc", "parking_lot"]
+std = ["alloc", "parking_lot", "pin-list/std"]
 default = ["std"]
 
 [dependencies]
 futures-core = { version = "^0.3", default-features = false }
 lock_api = "0.4.1"
 parking_lot = { version = "0.12.0", optional = true }
+pin-list = "0.1.0"
+pin-project-lite = "0.2.9"
 
 [dev-dependencies]
 futures = { version = "0.3.0", default-features = true, features=["async-await"] }

src/channel/mpmc.rs

@@ -3,7 +3,7 @@
 use crate::intrusive_double_linked_list::{LinkedList, ListNode};
 use crate::{
     buffer::{ArrayBuf, RingBuf},
-    utils::update_waker_ref,
+    utils::update_option_waker_ref,
     NoopLock,
 };
 use core::{marker::PhantomData, pin::Pin};
@@ -182,7 +182,7 @@ where
                 // to unregistered there can't be space available in the channel.
                 // However the caller might have passed a different `Waker`.
                 // In this case we need to update it.
-                update_waker_ref(&mut wait_node.task, cx);
+                update_option_waker_ref(&mut wait_node.task, cx);
                 (Poll::Pending, None, None)
             }
             SendPollState::SendComplete => {
@@ -289,7 +289,7 @@ where
                 // to unregistered there can't be any value in the channel in
                 // this state. However the caller might have passed a different `Waker`.
                 // In this case we need to update it.
-                update_waker_ref(&mut wait_node.task, cx);
+                update_option_waker_ref(&mut wait_node.task, cx);
                 Poll::Pending
             }
         }

src/channel/oneshot.rs

@@ -6,7 +6,7 @@ use super::{
 };
 use crate::{
     intrusive_double_linked_list::{LinkedList, ListNode},
-    utils::update_waker_ref,
+    utils::update_option_waker_ref,
     NoopLock,
 };
 use core::marker::PhantomData;
@@ -111,7 +111,7 @@ impl<T> ChannelState<T> {
                 // to unregistered there can't be any value in the channel in this state.
                 // However the caller might have passed a different `Waker`.
                 // In this case we need to update it.
-                update_waker_ref(&mut wait_node.task, cx);
+                update_option_waker_ref(&mut wait_node.task, cx);
                 Poll::Pending
             }
             RecvPollState::Notified => {

src/channel/oneshot_broadcast.rs

@@ -7,7 +7,7 @@ use super::{
 };
 use crate::{
     intrusive_double_linked_list::{LinkedList, ListNode},
-    utils::update_waker_ref,
+    utils::update_option_waker_ref,
     NoopLock,
 };
 use core::marker::PhantomData;
@@ -116,7 +116,7 @@ where
                 // to unregistered there can't be any value in the channel in this state.
                 // However the caller might have passed a different `Waker`.
                 // In this case we need to update it.
-                update_waker_ref(&mut wait_node.task, cx);
+                update_option_waker_ref(&mut wait_node.task, cx);
                 Poll::Pending
             }
             RecvPollState::Notified => {

src/channel/state_broadcast.rs

@@ -3,7 +3,7 @@
 use super::{ChannelSendError, CloseStatus};
 use crate::{
     intrusive_double_linked_list::{LinkedList, ListNode},
-    utils::update_waker_ref,
+    utils::update_option_waker_ref,
     NoopLock,
 };
 use core::marker::PhantomData;
@@ -288,7 +288,7 @@ where
                 // to unregistered there can't be any value in the channel in this state.
                 // However the caller might have passed a different `Waker`.
                 // In this case we need to update it.
-                update_waker_ref(&mut wait_node.task, cx);
+                update_option_waker_ref(&mut wait_node.task, cx);
                 Poll::Pending
             }
         }