Skip to content

Commit 6603b7b

Browse files
committed
Fix: distribute almanax feeds
1 parent 6bb8ba4 commit 6603b7b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

main.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,12 @@ func main() {
3838
if almFeeds, err = repo.GetAlmanaxFeeds([]uint64{}); err != nil {
3939
log.Fatal(err)
4040
}
41-
for _, feed := range almFeeds {
42-
go func(ctx context.Context, feed AlmanaxFeed) {
41+
go func(ctx context.Context) {
42+
for _, feed := range almFeeds {
4343
time.Sleep(time.Second * 1)
4444
go ListenAlmanax(ctx, feed)
45-
}(ctx, feed)
46-
}
45+
}
46+
}(ctx)
4747

4848
// twitter
4949
var twitterFeeds []TwitterFeed

0 commit comments

Comments
 (0)