diff --git a/modules/nats/cmd/nats-tools/keeper_integration_test.go b/modules/nats/cmd/nats-tools/keeper_integration_test.go index cacbb570..08a92477 100644 --- a/modules/nats/cmd/nats-tools/keeper_integration_test.go +++ b/modules/nats/cmd/nats-tools/keeper_integration_test.go @@ -244,7 +244,11 @@ func TestTheBusModuleRunsWhole(t *testing.T) { k = newKeeper() stop = run(k) eventually(t, "created p drafts", saidHas("created p drafts")) - eventually(t, "the replay heard", func() bool { info, _ := js.Consumer(ctx, "EVENTS", account.QueueConsumerName()); i, _ := info.Info(ctx); return i.NumPending == 0 && i.NumAckPending == 0 }) + eventually(t, "the replay heard", func() bool { + info, _ := js.Consumer(ctx, "EVENTS", account.QueueConsumerName()) + i, _ := info.Info(ctx) + return i.NumPending == 0 && i.NumAckPending == 0 + }) if saidHas("orphaned p drafts")() { t.Error("the replay at revision 4 orphaned what the first view at 9 asked") }