From f63aaa343c1362f0e93834250f28483ca21b83ee Mon Sep 17 00:00:00 2001 From: Eduard Urbach Date: Thu, 2 Nov 2017 07:25:40 +0100 Subject: [PATCH] Minor change --- jobs/avatars/avatars.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/jobs/avatars/avatars.go b/jobs/avatars/avatars.go index 60c82d64..f0fb8c7c 100644 --- a/jobs/avatars/avatars.go +++ b/jobs/avatars/avatars.go @@ -45,10 +45,8 @@ func main() { usersQueue := make(chan *arn.User, runtime.NumCPU()) StartWorkers(usersQueue, lib.RefreshAvatar) - allUsers, _ := arn.AllUsers() - // We'll send each user to one of the worker threads - for _, user := range allUsers { + for user := range arn.StreamUsers() { wg.Add(1) usersQueue <- user }