fix: correct issue with decoing

snapp-incubator · Oct 6, 2024 · 4c3014e · 4c3014e
1 parent a4312c3
commit 4c3014e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/client/jetstream.go b/internal/client/jetstream.go
@@ -209,7 +209,7 @@ func (client *Client) jetstreamSubscribe(h <-chan *Message, streamName string) {
 				zap.Error(err),
 			)
 
-			return
+			continue
 		}
 
 		latency := time.Since(payload.PublishTime).Seconds()
@@ -251,7 +251,7 @@ func (client *Client) coreSubscribe(subject string) {
 				zap.Error(err),
 			)
 
-			return
+			continue
 		}
 
 		latency := time.Since(payload.PublishTime).Seconds()