From ffa793426c7d65148b51db0ae64b40dde2db511f Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 5 Jan 2022 13:49:45 +0000 Subject: [PATCH] Add comment explaining where streams are defined --- setup/jetstream/nats.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go index 43cfc98b..eec68d82 100644 --- a/setup/jetstream/nats.go +++ b/setup/jetstream/nats.go @@ -67,7 +67,7 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (nats.JetStreamContex return nil, nil, nil } - for _, stream := range streams { + for _, stream := range streams { // streams are defined in streams.go name := cfg.TopicFor(stream.Name) info, err := s.StreamInfo(name) if err != nil && err != natsclient.ErrStreamNotFound {