diff --git a/src/cmd/cron/main.go b/src/cmd/cron/main.go index e817a5e..8f0b0f3 100644 --- a/src/cmd/cron/main.go +++ b/src/cmd/cron/main.go @@ -24,23 +24,14 @@ func Main(ctx context.Context) error { } func One(ctx context.Context) error { - feeds, err := feeds.New(ctx) + f, err := feeds.New(ctx) if err != nil { return err } - all, err := feeds.All(ctx) - if err != nil { - return err - } - - for _, feed := range all { - if err := one(ctx, feed); err != nil { - return err - } - } - - return nil + return f.ForEach(ctx, func(feed feeds.Feed) error { + return one(ctx, feed) + }) } func one(ctx context.Context, feed feeds.Feed) error {