fix waitgroup example

plabayo · Sep 29, 2024 · 055fe36 · 055fe36
1 parent 15309c3
commit 055fe36
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/shutdown.rs b/src/shutdown.rs
@@ -157,7 +157,7 @@ impl ShutdownBuilder<sealed::WithoutSignal> {
     pub fn build(self) -> Shutdown {
         let (zero_tx, zero_rx) = trigger();
 
-        let guard = ShutdownGuard::new(Receiver::pending(), zero_tx, Default::default());
+        let guard = ShutdownGuard::new(Receiver::closed(), zero_tx, Default::default());
 
         Shutdown {
             guard,

diff --git a/src/trigger.rs b/src/trigger.rs
@@ -150,6 +150,13 @@ impl Receiver {
         }
     }
 
+    /// Create a always-closed [`Receiver`].
+    pub(crate) fn closed() -> Self {
+        Self {
+            state: ReceiverState::Closed,
+        }
+    }
+
     /// Create a always-pending [`Receiver`].
     pub(crate) fn pending() -> Self {
         Self {