Fix confirm test

ella-to · May 18, 2024 · 1fe8d73 · 1fe8d73
1 parent dbee65e
commit 1fe8d73
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bus_test.go b/bus_test.go
@@ -51,6 +51,7 @@ func TestConfirmConsumer(t *testing.T) {
 		// as it could happen that the event can be sent before the consumer starts
 
 		for msg, err := range c.Get(ctx, bus.WithFromOldest(), bus.WithSubject("a.b.c"), bus.WithManualAck()) {
+			atomic.AddInt64(&hit, 1)
 
 			assert.NoError(t, err)
 			assert.NotNil(t, msg)
@@ -61,7 +62,6 @@ func TestConfirmConsumer(t *testing.T) {
 			assert.Equal(t, "a.b.c", evt.Subject)
 			assert.Equal(t, `"hello"`, string(evt.Data))
 
-			atomic.AddInt64(&hit, 1)
 			err = msg.Ack(ctx)
 			assert.NoError(t, err)