clean up

luno · Sep 12, 2024 · e98d22b · e98d22b
1 parent 80d135c
commit e98d22b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/testmock/await.go b/testmock/await.go
@@ -25,7 +25,7 @@ func AwaitConsumer(t *testing.T, cs reflex.CursorStore, consumerName string, eve
 			jtest.RequireNil(t, err)
 		}
 
-		if eID == eventID {
+		if eID >= eventID {
 			break
 		}