fix: remove return when stream doesn't exist

kumparan · Jan 24, 2022 · e0d0b45 · e0d0b45
1 parent 950a026
commit e0d0b45
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/jetstream.go b/jetstream.go
@@ -140,10 +140,7 @@ func (j *jsImpl) AddStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.St
 		return nil, ErrConnectionLost
 	}
 
-	streamInfo, err := j.jsCtx.StreamInfo(cfg.Name)
-	if err != nil {
-		return nil, err
-	}
+	streamInfo, _ := j.jsCtx.StreamInfo(cfg.Name)
 
 	if streamInfo == nil {
 		return j.jsCtx.AddStream(cfg, opts...)