diff --git a/integrations/jikan/relations.go b/integrations/jikan/relations.go index c5f60ff..8dae766 100644 --- a/integrations/jikan/relations.go +++ b/integrations/jikan/relations.go @@ -224,7 +224,7 @@ func buildAllowedWatchOrderEntries(result watchorder.WatchOrderResult, mode Watc 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.SetLimit(3) @@ -265,6 +265,12 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder. 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)) for res := range results { fetched = append(fetched, res)