Unbreak tests

This commit is contained in:
Kegan Dougal 2022-05-09 15:10:08 +01:00
parent f14e26c66b
commit 3ae86cec6a

View file

@ -100,7 +100,7 @@ func testSync(t *testing.T, dbType test.DBType) {
base, close := test.CreateBaseDendrite(t, dbType)
defer close()
jsctx, _ := jetstream.Prepare(base.ProcessContext, &base.Cfg.Global.JetStream)
jsctx, _ := base.NATS.Prepare(base.ProcessContext, &base.Cfg.Global.JetStream)
defer jetstream.DeleteAllStreams(jsctx, &base.Cfg.Global.JetStream)
var msgs []*nats.Msg
for _, ev := range room.Events() {