This commit is contained in:
Kegan Dougal 2022-05-09 15:52:46 +01:00
parent f7c4ec7862
commit a05fb192d8

View file

@ -25,7 +25,7 @@ type NATSInstance struct {
func DeleteAllStreams(js nats.JetStreamContext, cfg *config.JetStream) {
for _, stream := range streams { // streams are defined in streams.go
name := cfg.Prefixed(stream.Name)
js.DeleteStream(name)
_ = js.DeleteStream(name)
}
}