Feat: helper function to await a certain seq value in MetaTables for …

…projections
maxohq · Sep 13, 2024 · 4c403cb · 4c403cb
1 parent 3833546
commit 4c403cb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/projections/seq_checker.ex b/lib/projections/seq_checker.ex
@@ -3,6 +3,12 @@ defmodule Essig.Projections.SeqChecker do
   Checks, that given Cast modules reached certain SEQ value
   """
 
+  import Liveness
+
+  def await(modules, seq, timeout \\ 250) do
+    eventually(fn -> check_reached(modules, seq) == true end, timeout, 1)
+  end
+
   def check_reached(modules, seq) do
     conditions =
       Enum.map(modules, fn module ->