fix GetRecentItems

totegamma · Nov 6, 2023 · f13de5a · f13de5a
1 parent 70ff2ec
commit f13de5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/x/stream/service.go b/x/stream/service.go
@@ -194,7 +194,7 @@ func (s *service) GetRecentItems(ctx context.Context, streams []string, until ti
 			if err != nil {
 				log.Printf("Error: %v", err)
 				span.RecordError(err)
-				return nil, err
+				continue
 			}
 			for stream, chunk := range chunks {
 				items[stream] = chunk