consider also open triggered case

src/guard.rs

@@ -62,7 +62,7 @@ impl ShutdownGuard {
     ///
     /// Use [`ShutdownGuard::cancelled`] to wait for the cancellation (shutdown) to be requested.
     #[inline]
-    pub fn cancelled_peek(&self) -> bool {
+    pub fn cancelled_peek(&mut self) -> bool {
         self.0.cancelled_peek()
     }
 
@@ -207,7 +207,7 @@ impl WeakShutdownGuard {
     ///
     /// Use [`WeakShutdownGuard::cancelled`] to wait for the cancellation (shutdown) to be requested.
     #[inline]
-    pub fn cancelled_peek(&self) -> bool {
+    pub fn cancelled_peek(&mut self) -> bool {
         self.trigger_rx.closed()
     }
 

src/trigger.rs

@@ -48,6 +48,10 @@ enum SubscriberState {
 }
 
 impl Subscriber {
+    pub(crate) fn triggered(&self) -> bool {
+        self.state.load(Ordering::SeqCst)
+    }
+
     /// Returns the state of the Subscriber,
     /// which is used as a main driver in the Receiver's `Future::poll` implementation.
     ///
@@ -148,8 +152,11 @@ impl Receiver {
         }
     }
 
-    pub(crate) fn closed(&self) -> bool {
-        matches!(self.state, ReceiverState::Closed)
+    pub(crate) fn closed(&mut self) -> bool {
+        match &self.state {
+            ReceiverState::Open { sub, .. } => sub.triggered(),
+            ReceiverState::Closed => true,
+        }
     }
 }