From e98d22b6f5e10447bae603c2073c7e0df9c4c94e Mon Sep 17 00:00:00 2001 From: Andrew Wormald Date: Thu, 12 Sep 2024 10:07:28 +0100 Subject: [PATCH] clean up --- testmock/await.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/testmock/await.go b/testmock/await.go index 4d7ec88..8c8b553 100644 --- 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 }