package Ġga . nk 2 ish ere . dev . utils Ċ Ċ import Ġio . reactivex .* Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . dis pos ables . Composite Disposable Ċ import Ġio . reactivex . dis pos ables . Disposable Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ Ċ fun Ġ< T > ĠObservable < T >. subscribe D ( on Success : Ġ( T ) Ġ-> ĠUnit , ĠonError : Ġ(( Throwable ) Ġ-> ĠUnit ), Ġcomposite Disposable : ĠComposite Disposable ): ĠDis posable Ġ{ ĊĠĠĠ Ġval Ġdis posable Ġ= Ġthis . observe On ( Android Schedulers . main Thread ()). subscribe ( on Success , ĠonError ) ĊĠĠĠ Ġcomposite Disposable . add ( dis posable ) ĊĠĠĠ Ġreturn Ġdis posable Ċ } Ċ Ċ fun Ġ< T > ĠSingle < T >. subscribe D ( on Success : Ġ( T ) Ġ-> ĠUnit , ĠonError : Ġ(( Throwable ) Ġ-> ĠUnit ), Ġcomposite Disposable : ĠComposite Disposable ): ĠDis posable Ġ{ ĊĠĠĠ Ġval Ġdis posable Ġ= Ġthis . observe On ( Android Schedulers . main Thread ()). subscribe ( on Success , ĠonError ) ĊĠĠĠ Ġcomposite Disposable . add ( dis posable ) ĊĠĠĠ Ġreturn Ġdis posable Ċ } Ċ Ċ fun Ġ< T > ĠMaybe < T >. subscribe D ( on Success : Ġ( T ) Ġ-> ĠUnit , ĠonError : Ġ(( Throwable ) Ġ-> ĠUnit ), Ġcomposite Disposable : ĠComposite Disposable ): ĠDis posable Ġ{ ĊĠĠĠ Ġval Ġdis posable Ġ= Ġthis . observe On ( Android Schedulers . main Thread ()). subscribe ( on Success , ĠonError ) ĊĠĠĠ Ġcomposite Disposable . add ( dis posable ) ĊĠĠĠ Ġreturn Ġdis posable Ċ } Ċ Ċ fun ĠComp letable . subscribe D ( on Success : Ġ() Ġ-> ĠUnit , ĠonError : Ġ(( Throwable ) Ġ-> ĠUnit ), Ġcomposite Disposable : ĠComposite Disposable ): ĠDis posable Ġ{ ĊĠĠĠ Ġval Ġdis posable Ġ= Ġthis . observe On ( Android Schedulers . main Thread ()). subscribe ( on Success , ĠonError ) ĊĠĠĠ Ġcomposite Disposable . add ( dis posable ) ĊĠĠĠ Ġreturn Ġdis posable Ċ } Ċ Ċ fun Ġ< T > ĠSingle < T >. apply Schedulers () Ġ= Ġthis . subscribe On ( Schedulers . io ()). observe On ( Android Schedulers . main Thread ()) !! Ċ fun Ġ< T > ĠObservable < T >. apply Schedulers () Ġ= Ġthis . subscribe On ( Schedulers . io ()). observe On ( Android Schedulers . main Thread ()) !! Ċ fun ĠComp letable . apply Schedulers () Ġ= Ġthis . subscribe On ( Schedulers . io ()). observe On ( Android Schedulers . main Thread ()) !! Ċ fun Ġ< T > ĠFlow able < T >. apply Schedulers () Ġ= Ġthis . subscribe On ( Schedulers . io ()). observe On ( Android Schedulers . main Thread ()) !!