Changes after review

asynchronics · Oct 31, 2024 · 0732a7e · 0732a7e
1 parent 087f3c8
commit 0732a7e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/asynchronix-util/src/observables.rs b/asynchronix-util/src/observables.rs
@@ -19,7 +19,7 @@ where
 
 /// Observable state.
 ///
-/// This struct incapsulates state. Every state change is propagated to the
+/// This object encapsulates state. Every state change is propagated to the
 /// output.
 #[derive(Debug)]
 pub struct ObservableState<S, T>
@@ -67,6 +67,11 @@ where
         self.out.send(self.state.observe()).await;
         r
     }
+
+    /// Propagate value.
+    pub async fn propagate(&mut self) {
+        self.out.send(self.state.observe()).await;
+    }
 }
 
 impl<S, T> Deref for ObservableState<S, T>