better error handling

streamingfast · Jun 27, 2024 · 7accd60 · 7accd60
1 parent 5e86b30
commit 7accd60
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/rpc/clients.go b/rpc/clients.go
@@ -38,7 +38,8 @@ func WithClients[C any, V any](clients *Clients[C], f func(C) (v V, err error))
 	for {
 		client, err := clients.Next()
 		if err != nil {
-			return v, err
+			errs = multierror.Append(errs, err)
+			return v, errs
 		}
 		v, err := f(client)
 		if err != nil {