package Ġme . lu ke for it . space of aday . data . source Ċ Ċ import Ġandroidx . room . Empty ResultSet Exception Ċ import Ġio . reactivex . Single Ċ import Ġme . lu ke for it . space of aday . common . Utils Ċ import Ġme . lu ke for it . space of aday . data . mapper . Ap od Mapper Ċ import Ġme . lu ke for it . space of aday . data . model . Ap od Ċ import Ġme . lu ke for it . space of aday . data . source . cache . Ap od Dao Ċ Ċ class ĠSpace Repository Impl ( private Ġval Ġrepository : ĠAp od Repository , Ġprivate Ġval Ġap od Dao : ĠAp od Dao , Ġprivate Ġval Ġmapper : ĠAp od Mapper ) Ġ: ĠSpace Repository Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġfetch All Ap ods (): ĠSingle < List < Ap od >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġap od Dao . fetch All (). map Ġ{ Ġit . map ( mapper :: map ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġfetch Ap od ( date : ĠString ): ĠSingle < Ap od > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġap od Dao . fetch By ( Utils . getDate As Int ( date )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map ( mapper :: map ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. onError Resume Next Ġ{ Ġthrowable Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( throwable Ġis ĠEmpty ResultSet Exception ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrepository . fetch Ap od ( date ). do On Success Ġ{ Ġap od Ġ-> Ġap od Dao . insert All ( listOf ( mapper . map ( ap od ))) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠSingle . error ( throwable ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ