package Ġcom . cyber log ite c . fre ight 9 . lib . data Ċ Ċ import Ġcom . cyber log ite c . fre ight 9 . lib . db . Payment Dao Ċ import Ġcom . cyber log ite c . fre ight 9 . lib . model . Payment Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġtim ber . log . Tim ber Ċ Ċ class ĠPayment Repository ( val Ġpayment Dao : ĠPayment Dao ): ĠPayment Repository Type Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġstore Payment In Db ( payment : ĠPayment ) Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . from Callable Ġ{ Ġpayment Dao . insert ( payment ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTim ber . d (" f 9 : Ġ" Ġ+ Ġ" Inserted Ġ${ payment } Ġcarrier Ġfrom ĠAPI Ġin ĠDB ...") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġstore Payments In Db ( payments : ĠList < Payment >) Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . from Callable Ġ{ Ġpayment Dao . insert All ( payments ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTim ber . d (" f 9 : Ġ" Ġ+ Ġ" Inserted Ġ${ payments . size } Ġcar riers Ġfrom ĠAPI Ġin ĠDB ...") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġget Payments From Db ( type : ĠString ): ĠObservable < List < Payment >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġpayment Dao . get Payments ( type ). filter Ġ{ Ġit . isNotEmpty () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. to Observable () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTim ber . d (" f 9 : Ġ" Ġ+ Ġ" Dispatch ing Ġ${ it . size } Ġpayments Ġfrom ĠDB ...") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġget Payments From Db (): ĠObservable < List < Payment >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġpayment Dao . get Payments (). filter Ġ{ Ġit . isNotEmpty () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. to Observable () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠTim ber . d (" f 9 : Ġ" Ġ+ Ġ" Dispatch ing Ġ${ it . size } Ġpayments Ġfrom ĠDB ...") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ