package Ġio . x apk . apk installer . utils . rx Ċ Ċ import Ġandroid . content . Context Ċ import Ġandroidx . fragment . app . Fragment Ċ import Ġcom . trello . rx lifecycle 3 . android . Activity Event Ċ import Ġcom . trello . rx lifecycle 3 . android . Fragment Event Ċ import Ġcom . trello . rx lifecycle 3 . components . preference . Rx Preference Fragment Compat Ċ import Ġcom . trello . rx lifecycle 3 . components . support . Rx AppCompatActivity Ċ import Ġcom . trello . rx lifecycle 3 . components . support . Rx AppCompat Dialog Fragment Ċ import Ġcom . trello . rx lifecycle 3 . components . support . Rx Fragment Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observable Transformer Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . functions . Function Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġio . x apk . apk installer . model . bean . ApiError Ċ Ċ object ĠRx Observable Transformer Ġ{ ĊĊĠĠĠ Ġfun Ġ< T > Ġio _ main (): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable Transformer Ġ{ Ġupstream Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġupstream . subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. unsubscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġerror Result ( mContext : ĠContext ): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable Transformer Ġ{ Ġupstream Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġupstream . onError Resume Next ( Function Ġ{ ĠObservable . error ( ApiError . handle Throwable ( mContext , Ġit )) Ġ}) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġcreate Data ( t : ĠT ): ĠObservable < T > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable . create Ġ{ Ġobservable Emitter Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ(! observable Emitter . is Disposed ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġobservable Emitter . onNext ( t ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġobservable Emitter . onComplete () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T , ĠC Ġ: ĠContext > Ġadd Disposable ( mContext : ĠC ): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġadd Multi Disposable ( mContext ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġ< T , ĠC > Ġadd Multi Disposable ( mContext : ĠC ): ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġwhen Ġ( mContext ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis ĠRx Fragment Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind To Lifecycle < T >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind Until Event < T >( Fragment Event . DESTROY _ VIEW ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis ĠRx Preference Fragment Compat Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind To Lifecycle < T >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind Until Event < T >( Fragment Event . DESTROY _ VIEW ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis ĠRx AppCompatActivity Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind To Lifecycle < T >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind Until Event < T >( Activity Event . DESTROY ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis ĠRx AppCompat Dialog Fragment Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind To Lifecycle < T >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠmContext . bind Until Event < T >( Fragment Event . DESTROY _ VIEW ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġelse Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠObservable Transformer Ġ{ Ġupstream Ġ-> Ġupstream Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ