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)