package Ġtasks Ċ Ċ import Ġcontributors .* Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Scheduler Ċ import Ġio . reactivex . Single Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ Ċ fun Ġload Contribut ors Reactive ( ĊĠĠĠ Ġservice : ĠGitHub Service , ĊĠĠĠ Ġreq : ĠRequest Data , ĊĠĠĠ Ġscheduler : ĠScheduler Ġ= ĠS chedulers . io () Ċ ): ĠSingle < List < User >> Ġ{ ĊĠĠĠ Ġval Ġrepos : ĠObservable < Repo > Ġ= Ġservice ĊĠĠĠĠĠĠĠ Ġ. get Org Repos Rx ( req . org ) ĊĠĠĠĠĠĠĠ Ġ. subscribe On ( scheduler ) ĊĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ Ġresponse Ġ-> Ġlog Repos ( req , Ġresponse ) Ġ} ĊĠĠĠĠĠĠĠ Ġ. flatMap Iterable Ġ{ Ġit . body List () Ġ} ĊĊĠĠĠ Ġval Ġall Users : ĠSingle < List < User >> Ġ= Ġrepos ĊĠĠĠĠĠĠĠ Ġ. flatMap Ġ{ Ġrepo Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġservice . get Repo Contribut ors Rx ( req . org , Ġrepo . name ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( scheduler ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ Ġresponse Ġ-> Ġlog Users ( repo , Ġresponse ) Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ. flatMap Iterable Ġ{ Ġit . body List () Ġ} ĊĠĠĠĠĠĠĠ Ġ. toList () ĊĊĠĠĠ Ġreturn Ġall Users . map Ġ{ Ġit . aggregate () Ġ} Ċ }