package Ġme . s aket . d ank . reddit . j raw Ċ Ċ import Ġio . reactivex . Comp letable Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Single Ċ import Ġme . s aket . d ank . reddit . Red dit Ċ import Ġnet . de an . j raw . Red dit Client Ċ import Ġnet . de an . j raw . models . Sub reddit Ċ import Ġnet . de an . j raw . pagination . Paginator Ċ Ċ /** ĠTODO : ĠShould Ġbe Ġmerged Ġto Ġ[ J raw LoggedIn User ] Ġ*/ Ċ class ĠJ raw Subscriptions ( private Ġval Ġclients : ĠObservable < Red dit Client >) Ġ: ĠRed dit . Subscriptions Ġ{ ĊĊĠ Ġoverride Ġfun Ġuser Subscriptions (): ĠSingle < List < Sub reddit >> Ġ{ ĊĠĠĠ Ġreturn Ġclients ĊĠĠĠĠĠĠĠ Ġ. first Or Error () ĊĠĠĠĠĠĠĠ Ġ. map Ġ{ ĊĠĠĠĠĠĠĠĠĠ Ġit . me () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. sub redd its (" subscriber ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. limit ( Paginator . RE COMM ENDED _ MAX _ LIMIT ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. build () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. accum ulate Merged ( 2 0 0 ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠ Ġ} ĊĊĠ Ġoverride Ġfun Ġadd ( sub reddit : ĠSub reddit ): ĠComp letable Ġ{ ĊĠĠĠ Ġreturn Ġclients ĊĠĠĠĠĠĠĠ Ġ. first Or Error () ĊĠĠĠĠĠĠĠ Ġ. flatMap Comp letable Ġ{ ĠComp letable . from Action Ġ{ Ġit . sub reddit ( sub reddit . name ). subscribe () Ġ} Ġ} ĊĠ Ġ} ĊĊĠ Ġoverride Ġfun Ġremove ( sub reddit : ĠSub reddit ): ĠComp letable Ġ{ ĊĠĠĠ Ġreturn Ġclients ĊĠĠĠĠĠĠĠ Ġ. first Or Error () ĊĠĠĠĠĠĠĠ Ġ. flatMap Comp letable Ġ{ ĠComp letable . from Action Ġ{ Ġit . sub reddit ( sub reddit . name ). unsubscribe () Ġ} Ġ} ĊĠ Ġ} Ċ } Ċ