package Ġcom . gray h erring . dev talk s . data . repository . api Ċ Ċ import Ġcom . gray h erring . dev talk s . base . util . apply Schedulers Ċ import Ġcom . gray h erring . dev talk s . data . model . Talk Ċ import Ġio . reactivex . Observable Ċ Ċ open Ġclass ĠDev Talk ApiClient ( val Ġdev Talk Api : ĠDev Talk Api ) Ġ: ĠDev Talk Api Ġ{ ĊĊĠ Ġoverride Ġfun Ġtalk s (): ĠObservable < List < Talk >> Ġ= Ġdev Talk Api . talk s (). apply Schedulers () ĊĠ Ġoverride Ġfun Ġtalk ( id : ĠString ): ĠObservable < Talk ?> Ġ= Ġdev Talk Api . talk ( id ). apply Schedulers () ĊĠ Ġoverride Ġfun Ġinsert OrUpdate ( var arg Ġtalk s : ĠTalk ): ĠObservable < Talk > Ġ= Ġdev Talk Api . insert OrUpdate (* talk s ). apply Schedulers () ĊĠ Ġoverride Ġfun Ġdelete ( talk : ĠTalk ): ĠObservable < Talk > Ġ= Ġdev Talk Api . delete ( talk ). apply Schedulers () Ċ }