From f13de5a488253c82b5f8ba75cbc5010fd230171a Mon Sep 17 00:00:00 2001 From: totegamma Date: Mon, 6 Nov 2023 18:56:06 +0900 Subject: [PATCH] fix GetRecentItems --- x/stream/service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/x/stream/service.go b/x/stream/service.go index 0ce9fc4c..0f90e8d0 100644 --- 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