mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 03:24:40 -07:00
@@ -7040,7 +7040,7 @@ func TestNoRaceJetStreamInterestStreamCheckInterestRaceBug(t *testing.T) {
|
||||
}
|
||||
|
||||
// Wait til ackfloor is correct for all consumers.
|
||||
checkFor(t, 10*time.Second, 100*time.Millisecond, func() error {
|
||||
checkFor(t, 20*time.Second, 100*time.Millisecond, func() error {
|
||||
for _, s := range c.servers {
|
||||
mset, err := s.GlobalAccount().lookupStream("TEST")
|
||||
require_NoError(t, err)
|
||||
|
||||
Reference in New Issue
Block a user