package Ġcom . rx java 2 . android . samples . ui . r xb us Ċ Ċ import Ġandroid . os . Bundle Ċ import Ġandroid . view . View Ċ import Ġandroid . widget . Button Ċ import Ġandroid . widget . TextView Ċ import Ġandroidx . appcompat . app . AppCompatActivity Ċ import Ġcom . rx java 2 . android . samples . My Application Ċ import Ġcom . rx java 2 . android . samples . R Ċ import Ġcom . rx java 2 . android . samples . model . Events . Auto Event Ċ import Ġcom . rx java 2 . android . samples . model . Events . Tap Event Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . dis pos ables . Composite Disposable Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġkotlinx . android . synt hetic . main . activity _ r xb us .* Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġa mit she k har Ġon Ġ 0 6 / 0 2 / 1 7 . Ċ Ġ*/ Ċ class ĠRx Bus Activity Ġ: ĠAppCompatActivity () Ġ{ ĊĠĠĠ Ġ// var ĠtextView : ĠTextView ? Ġ= Ġnull ĊĠĠĠ Ġvar Ġbutton : ĠButton ? Ġ= Ġnull ĊĠĠĠ Ġprivate Ġval Ġdis pos ables : ĠComposite Disposable ? Ġ= ĠComposite Disposable () ĊĠĠĠ Ġoverride Ġfun Ġon Destroy () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Destroy () ĊĠĠĠĠĠĠĠ Ġdis pos ables !!. clear () Ġ// Ġdo Ġnot Ġsend Ġevent Ġafter Ġactivity Ġhas Ġbeen Ġdestroyed ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠonCreate ( savedInstanceState : ĠBundle ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . onCreate ( savedInstanceState ) ĊĠĠĠĠĠĠĠ ĠsetContentView ( R . layout . activity _ r xb us ) ĊĠĠĠĠĠĠĠ Ġ// textView Ġ= ĠfindViewById < TextView ? >( R . id . textView ) Ċ // ĠĠĠĠĠĠĠ Ġbutton Ġ= ĠfindViewById < Button ? >( R . id . button ) ĊĠĠĠĠĠĠĠ Ġdis pos ables !!. add (( application Ġas ĠMy Application ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. bus () !! ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. to Observable () !! ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe Ġ{ Ġ` object ` Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ(` object ` Ġis ĠAuto Event ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠtextView !!. setText (" Auto ĠEvent ĠReceived ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġif Ġ(` object ` Ġis ĠT ap Event ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠtextView !!. setText (" Tap ĠEvent ĠReceived ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠĠĠĠĠ Ġbutton !!. setOnClickListener ( View . OnClickListener Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ( application Ġas ĠMy Application ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. bus () !! ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. send ( Tap Event ()) ĊĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġval ĠTAG Ġ= ĠRx Bus Activity :: class . java . simple Name ĊĠĠĠ Ġ} Ċ }