From 9cd03a7430cc6b7dca3f5a97a08a5a799a84c673 Mon Sep 17 00:00:00 2001 From: jochen Date: Tue, 10 Nov 2026 04:12:04 +0100 Subject: [PATCH] =?UTF-8?q?H3:=20the=20row=20of=20sayOnce=20feeds=20the=20?= =?UTF-8?q?old=20JetStream=20client's=20own=20no=20responders,=20nats.ErrN?= =?UTF-8?q?oStreamResponse=20(issue=201966,=20ADR=200668=20=C2=A71;=20revi?= =?UTF-8?q?ew=20round=201,=20finding=202)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Claude-Session: https://claude.ai/code/session_01JG73KEq4zoDfM9WtYpcQgZ --- internal/link/have_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/link/have_test.go b/internal/link/have_test.go index 76cc969..18f50d8 100644 --- a/internal/link/have_test.go +++ b/internal/link/have_test.go @@ -409,11 +409,11 @@ func TestTheNodeKeyCarriesTheNodesFacts(t *testing.T) { catalogue.UseSeats(all) q.RestateReads(context.Background()) - // And the publish itself (sayOnce): through no responders and a deadline it is published again under one message id, + // And the publish itself (sayOnce): through no responders, as the old JetStream client says it, and a deadline it is published again under one message id, // so the stream takes it once. t.Cleanup(busretry.Waits(10*time.Second, time.Millisecond, 2*time.Millisecond)) var ids []string - faults := []error{nats.ErrNoResponders, context.DeadlineExceeded, nil} + faults := []error{nats.ErrNoStreamResponse, context.DeadlineExceeded, nil} if err := sayOnce(func(id string) error { ids = append(ids, id); return faults[len(ids)-1] }, "s", []byte("{}")); err != nil || len(ids) != 3 || ids[0] != ids[2] || ids[0] == "" { t.Errorf("a publish through two faults: %v, ids %q", err, ids)