package Ġru . mer k ul ye vs ash a . core android . presentation čĊč Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers č Ċ import Ġio . reactivex . dis pos ables . Disposable č Ċ import Ġru . mer k ul ye vs ash a . core . domain . Articles Interactor č Ċ import Ġru . mer k ul ye vs ash a . core . models . Article čĊč Ċ class ĠSearch Article Handler ( čĊĠĠĠ Ġprivate Ġval Ġarticles Interactor : ĠArticles Interactor , čĊĠĠĠ Ġprivate Ġval Ġby User Activities : ĠBoolean , čĊĠĠĠ Ġprivate Ġval Ġshow Progress : Ġ() Ġ-> ĠUnit , čĊĠĠĠ Ġprivate Ġval Ġhide Progress : Ġ() Ġ-> ĠUnit , čĊĠĠĠ Ġprivate Ġval Ġsuccess : Ġ( List < Article >) Ġ-> ĠUnit , čĊĠĠĠ Ġprivate Ġval Ġfailure : Ġ() Ġ-> ĠUnit č Ċ ) Ġ{ čĊĠĠĠ Ġfun Ġon Search Articles ( search Text : ĠString ?): ĠDis posable Ġ{ čĊĠĠĠĠĠĠĠ Ġreturn Ġarticles Interactor . search Articles ( search Text , Ġby User Activities ) čĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) čĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Subscribe Ġ{ Ġshow Progress () Ġ} čĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. do After Terminate Ġ{ Ġhide Progress () Ġ} čĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( čĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ Ġsuccess ( it ) Ġ}, čĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ čĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfailure () čĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}) čĊĠĠĠ Ġ} č Ċ }