package Ġru . nbsp . push ka . repository . subscription Ċ Ċ import Ġru . nbsp . push ka . mapper . presentation . subscription . Presentation ListItem Mapper Ċ import Ġru . nbsp . push ka . network . service . Push ka Subscription Service Ċ import Ġru . nbsp . push ka . presentation . core . model . subscription . Presentation ListItem Ċ import Ġru . nbsp . push ka . util . Schedulers Utils Ċ import Ġrx . Observable Ċ import Ġjava . util .* Ċ Ċ /** Ċ Ġ* ĠCreated Ġby ĠDim or in ny Ġon Ġ 1 3 . 0 4 . 1 6 . Ċ Ġ*/ Ċ class ĠApi ListItem Repository ( ĊĠĠĠĠĠĠĠ Ġval Ġapi Push ka : ĠPush ka Subscription Service , ĊĠĠĠĠĠĠĠ Ġval Ġpresentation List Mapper : ĠPresentation ListItem Mapper , ĊĠĠĠĠĠĠĠ Ġval Ġs chedulers Utils : ĠS chedulers Utils ) Ġ: ĠListItem Repository Ġ{ ĊĊĠĠĠ Ġoverride Ġfun ĠgetList Items ( source Id : ĠString , Ġlist Id : ĠString , Ġquery : ĠString ): ĠObservable < List < Presentation ListItem >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġapi Push ka . getList Items ( source Id , Ġlist Id , Ġquery ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġvar Ġresult Ġ= ĠArrayList < Presentation ListItem >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfor Ġ( alert Ġin Ġit . list ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġresult . add ( presentation List Mapper . from Network ListItem ( alert )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġresult ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. compose ( schedul ers Utils . apply Schedulers < List < Presentation ListItem >> ()) ĊĠĠĠ Ġ} Ċ }