refactor(paxos): start splitting out leader election into a separate …

…module
hydro-project · Oct 8, 2024 · 09146c4 · 09146c4
1 parent f5fd452
commit 09146c4
Show file tree

Hide file tree

Showing 3 changed files with 633 additions and 646 deletions.
diff --git a/hydroflow_plus/src/singleton.rs b/hydroflow_plus/src/singleton.rs
@@ -580,6 +580,10 @@ impl<'a, T, N: Location<'a>> Optional<T, Bounded, Tick, N> {
             .map(q!(|(d, _signal)| d))
     }
 
+    pub fn then<U>(self, value: Singleton<U, Bounded, Tick, N>) -> Optional<U, Bounded, Tick, N> {
+        value.continue_if(self)
+    }
+
     pub fn continue_unless<U>(
         self,
         other: Optional<U, Bounded, Tick, N>,