cron.One.feeds.FOrEach

main
Bel LaPointe 2025-04-27 11:28:28 -06:00
parent f57408d003
commit baa97ab62d
1 changed files with 4 additions and 13 deletions

View File

@ -24,23 +24,14 @@ func Main(ctx context.Context) error {
} }
func One(ctx context.Context) error { func One(ctx context.Context) error {
feeds, err := feeds.New(ctx) f, err := feeds.New(ctx)
if err != nil { if err != nil {
return err return err
} }
all, err := feeds.All(ctx) return f.ForEach(ctx, func(feed feeds.Feed) error {
if err != nil { return one(ctx, feed)
return err })
}
for _, feed := range all {
if err := one(ctx, feed); err != nil {
return err
}
}
return nil
} }
func one(ctx context.Context, feed feeds.Feed) error { func one(ctx context.Context, feed feeds.Feed) error {