package Ġtasks Ċ Ċ import Ġcontributors . GitHub Service Ċ import Ġcontributors . Request Data Ċ import Ġcontributors . User Ċ import Ġkotlinx . coroutines .* Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġkotlinx . coroutines . flow . channel Flow Ċ import Ġkotlinx . coroutines . flow . collect Indexed Ċ import Ġkotlinx . coroutines . flow . scan Reduce Ċ Ċ fun Ġload Contribut ors Reactive ( ĊĠĠĠ Ġservice : ĠGitHub Service , ĊĠĠĠ Ġreq : ĠRequest Data Ċ ): ĠFlow < List < User >> Ġ= Ġchannel Flow Ġ{ ĊĠĠĠ Ġwith Context ( Dispatch ers . IO ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġrepos Ġ= Ġservice . get Org Repos ( req . org ) ĊĠĠĠĠĠĠĠ Ġfor Ġ( repo Ġin Ġrepos ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlaunch Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġusers Ġ= Ġservice . get Repo Contribut ors ( req . org , Ġrepo . name ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsend ( users ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }. scan Reduce Ġ{ Ġaccumulator , Ġvalue Ġ-> Ġ( accumulator Ġ+ Ġvalue ). aggregate () Ġ}