mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -3809,6 +3809,7 @@ func TestNoRaceJetStreamClusterStreamReset(t *testing.T) {
|
||||
|
||||
// Simulate a low level write error on our consumer and make sure we can recover etc.
|
||||
cl = c.consumerLeader("$G", "TEST", "d1")
|
||||
require_True(t, cl != nil)
|
||||
mset, err = cl.GlobalAccount().lookupStream("TEST")
|
||||
if err != nil {
|
||||
t.Fatalf("Unexpected error: %v", err)
|
||||
|
||||
Reference in New Issue
Block a user