refactor: split fetchRelationResults to satisfy funlen
This commit is contained in:
@@ -224,7 +224,7 @@ func buildAllowedWatchOrderEntries(result watchorder.WatchOrderResult, mode Watc
|
|||||||
return allowedEntries, seen
|
return allowedEntries, seen
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder.WatchOrderEntry) []fetchResult {
|
func (c *Client) fetchRelationEntries(ctx context.Context, entries []watchorder.WatchOrderEntry) chan fetchResult {
|
||||||
g, gCtx := errgroup.WithContext(ctx)
|
g, gCtx := errgroup.WithContext(ctx)
|
||||||
g.SetLimit(3)
|
g.SetLimit(3)
|
||||||
|
|
||||||
@@ -265,6 +265,12 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder.
|
|||||||
close(results)
|
close(results)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
return results
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder.WatchOrderEntry) []fetchResult {
|
||||||
|
results := c.fetchRelationEntries(ctx, entries)
|
||||||
|
|
||||||
fetched := make([]fetchResult, 0, len(entries))
|
fetched := make([]fetchResult, 0, len(entries))
|
||||||
for res := range results {
|
for res := range results {
|
||||||
fetched = append(fetched, res)
|
fetched = append(fetched, res)
|
||||||
|
|||||||
Reference in New Issue
Block a user