From 296951d8016dabb63dae78dd14bb54e90ae1c91e Mon Sep 17 00:00:00 2001 From: Rogee Date: Mon, 24 Aug 2026 14:27:21 +0800 Subject: [PATCH] test(HH-613): wait for XAck before subscriber close (#165) Co-authored-by: Rogee --- .../service/notification_delivery_lifecycle_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/backend/internal/service/notification_delivery_lifecycle_test.go b/backend/internal/service/notification_delivery_lifecycle_test.go index 186ca128..d8e8e8ba 100644 --- a/backend/internal/service/notification_delivery_lifecycle_test.go +++ b/backend/internal/service/notification_delivery_lifecycle_test.go @@ -221,15 +221,15 @@ func TestNotificationShutdownWaitsForRedisStreamXAck(t *testing.T) { require.NoError(t, publisherClient.Ping(context.Background()).Err()) releaseAck() + select { + case <-gate.done: + case <-time.After(5 * time.Second): + t.Fatal("timed out waiting for XAck completion") + } releaseSubscriberClose() require.NoError(t, <-closeDone) require.NoError(t, <-runDone) handlers.Stop() - select { - case <-gate.done: - default: - t.Fatal("router closed without completing XAck") - } pending, err = publisherClient.XPending(context.Background(), topic, gate.group).Result() require.NoError(t, err) require.Zero(t, pending.Count)