package Ġcom . github . pre mn irm al . ticker . components Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . subjects . Publish Subject Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġpre mn irm al Ġon Ġ 2 / 2 6 / 1 6 . Ċ Ġ* Ċ Ġ* ĠThe Ġg het to Ġevent Ġbus ! Ċ Ġ*/ Ċ class ĠRx Bus Ġ{ ĊĊĠ Ġprivate Ġval Ġ_ bus Ġ= ĠPublish Subject . create < Any >() ĊĊĠ Ġfun Ġpost ( o : ĠAny ): ĠBoolean Ġ{ ĊĠĠĠ Ġ_ bus . onNext ( o ) ĊĠĠĠ Ġreturn Ġ_ bus . has Observer s () ĊĠ Ġ} ĊĊĠ Ġ/** ĊĠĠ Ġ* ĠSubscribe Ġto Ġany Ġevent ĊĠĠ Ġ*/ ĊĠ Ġfun Ġfor Any Event (): ĠObservable < Any > Ġ= Ġ_ bus . observe On ( Android Schedulers . main Thread ()) ĊĊĠ Ġ/** ĊĠĠ Ġ* ĠSubscribe Ġto Ġa Ġspecific Ġevent Ġtype ĊĠĠ Ġ*/ ĊĠ Ġfun Ġ< T > Ġfor EventType ( eventType : ĠClass < T >): ĠObservable < T > Ġ= ĊĠĠĠĠĠ Ġ_ bus . of Type ( eventType ). observe On ( Android Schedulers . main Thread ()) Ċ } Ċ