diff --git a/src/BirdsiteLive.Pipeline/Processors/RetrieveFollowersProcessor.cs b/src/BirdsiteLive.Pipeline/Processors/RetrieveFollowersProcessor.cs index 57e3e49..a34adfb 100644 --- a/src/BirdsiteLive.Pipeline/Processors/RetrieveFollowersProcessor.cs +++ b/src/BirdsiteLive.Pipeline/Processors/RetrieveFollowersProcessor.cs @@ -20,12 +20,17 @@ namespace BirdsiteLive.Pipeline.Processors public async Task> ProcessAsync(UserWithDataToSync[] userWithTweetsToSyncs, CancellationToken ct) { - //TODO multithread this + List todo = new List(); foreach (var user in userWithTweetsToSyncs) { - var followers = await _followersDal.GetFollowersAsync(user.User.Id); - user.Followers = followers; + var t = Task.Run( + async() => { + var followers = await _followersDal.GetFollowersAsync(user.User.Id); + user.Followers = followers; + }); + todo.Add(t); } + await Task.WhenAll(todo); return userWithTweetsToSyncs; }