package Ġcom . dom ker . base . thread Ċ Ċ import Ġio . reactivex . rx java 3 . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . rx java 3 . core . Flow able Transformer Ċ import Ġio . reactivex . rx java 3 . core . Observable Transformer Ċ import Ġio . reactivex . rx java 3 . core . Single Transformer Ċ import Ġio . reactivex . rx java 3 . schedul ers . Schedulers Ċ Ċ /** Ċ Ġ* ĠRx Java ä¸Ń ä¸ĢäºĽ å°ģè£ħ Ċ Ġ* Ċ Ġ* Ċ Ġ* ĠCreated Ġby Ġw an lip eng Ġon Ġ 2 0 1 9 / 2 / 9 Ġ 1 1 : 5 7 ĠPM Ċ Ġ*/ Ċ object ĠRx Helper Ġ{ ĊĊĠĠĠ Ġfun Ġ< T > Ġobservable IO 2 Main (): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable Transformer Ġ{ Ġupstream Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġupstream . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġflow able IO 2 Main (): ĠFlow able Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠFlow able Transformer Ġ{ Ġupstream Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġupstream . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġsingle IO 2 Main (): ĠSingle Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠSingle Transformer Ġ{ Ġupstream Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġupstream . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ// ĊĠĠĠ Ġ// ĠĠĠ Ġprivate Ġstatic Ġ< T > ĠObservable Source < T > Ġcompose Context ( Context Ġcontext , ĠObservable < T > Ġobservable ) Ġ{ ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠ Ġif Ġ( context Ġinstanceof ĠRx Activity ) Ġ{ ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġobservable . compose ((( Rx Activity ) Ġcontext ). bind Until Event ( Activity Event . DESTROY )); ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠ Ġ} Ġelse Ġif Ġ( context Ġinstanceof ĠRx Fragment Activity ) Ġ{ ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġobservable . compose ((( Rx Fragment Activity ) Ġcontext ). bind Until Event ( Activity Event . DESTROY )); ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠ Ġ} Ġelse Ġif Ġ( context Ġinstanceof ĠRx AppCompatActivity ) Ġ{ ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġobservable . compose ((( Rx AppCompatActivity ) Ġcontext ). bind Until Event ( Activity Event . DESTROY )); ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġobservable ; ĊĠĠĠ Ġ// ĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ// ĠĠĠ Ġ} Ċ }