package Ġcom . p ize . cash boy . utils Ċ Ċ import Ġcom . p ize . cash boy . base . I Base View Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observable Transformer Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ Ċ /** Ċ Ġ*@ fileName ĠRx Utils Ċ Ġ*@ author Ġw ang xia od ong Ċ Ġ*@ data Ġ 2 0 1 8 / 5 / 2 Ġä¸ĭåįĪ 2 : 3 8 Ċ Ġ*@ describe ĠTODO Ċ Ġ*/ Ċ object ĠRx Utils Ġ{ ĊĊĊĠĠĠ Ġfun Ġ< T > Ġapply Schedulers Loading ( view : ĠI Base View ): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable Transformer Ġ{ Ġobservable Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobservable . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Subscribe Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġview . show Loading () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}. subscribe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do Finally Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġview . hide Loading () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġapply Schedulers (): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable Transformer Ġ{ Ġobservable Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobservable . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ }