package Ġcom . net guru . re pol ibr x . sample . feature . edit Ċ Ċ import Ġandroidx . lifecycle . ViewModel Ċ import Ġcom . net guru . re pol ibr x . Repo Lib Rx Ċ import Ġcom . net guru . re pol ibr x . sample . feature . demo . data . Demo Data Entity Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . dis pos ables . Composite Disposable Ċ import Ġio . reactivex . rx kotlin . plus Assign Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġjavax . inject . Inject Ċ Ċ class ĠUpdate Item ViewModel Ġ@ Inject Ġconstructor ( ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġrepo Lib Rx : ĠRepo Lib Rx < Demo Data Entity > Ċ ) Ġ: ĠViewModel () Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġcomposite Disposable Ġ= ĠComposite Disposable () ĊĊĠĠĠ Ġfun Ġupdate ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġitem ToUpdate : ĠDemo Data Entity , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonComplete Action : Ġ() Ġ-> ĠUnit , ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonError : Ġ( Throwable ) Ġ-> ĠUnit ĊĠĠĠ Ġ) Ġ{ ĊĠĠĠĠĠĠĠ Ġcomposite Disposable Ġ+= Ġrepo Lib Rx . update ( item ToUpdate ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( onComplete Action , ĠonError ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Cle ared () Ġ{ ĊĠĠĠĠĠĠĠ Ġcomposite Disposable . clear () ĊĠĠĠĠĠĠĠ Ġsuper . on Cle ared () ĊĠĠĠ Ġ} Ċ }