From 441a85f00f7374963690d58f6aba187da18fa260 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Zolt=C3=A1n=20Papp?= Date: Tue, 31 Mar 2026 23:12:25 +0200 Subject: [PATCH] [client] Update Close error message in test for clarity --- flow/client/client_test.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/flow/client/client_test.go b/flow/client/client_test.go index c7e46124d..f19e073fe 100644 --- a/flow/client/client_test.go +++ b/flow/client/client_test.go @@ -380,14 +380,15 @@ func TestNewClient_CloseVerify(t *testing.T) { case <-closeDone: return case <-time.After(2 * time.Second): - t.Fatal("Receive did not return after Close — stuck in retry loop") + t.Fatal("Close did not return — blocked in retry loop") } } func TestClose_WhileReceiving(t *testing.T) { server := newTestServer(t) - client, _ := flow.NewClient("http://"+server.addr, "test-payload", "test-signature", 1*time.Second) + client, err := flow.NewClient("http://"+server.addr, "test-payload", "test-signature", 1*time.Second) + require.NoError(t, err) ctx := context.Background() // no timeout — intentional go func() {