RxBus

An event bus in 27 LOC.

1. Add Kotlin, RxJava 1 and RxAndroid to you project.

2. Copy and past the RxBus code into project

object RxBus {
privateval mBusSubject =SerializedSubject(BehaviorSubject.create<Any>())
lateinitvar uiScheduler:Scheduleroperatorfuninvoke(sch:Scheduler) { uiScheduler = sch }
fun <T> register(eventClass:Class<T>): Observable<T> = mBusSubject.filter({ event -> eventClass.isInstance(event) })
.observeOn(uiScheduler)
.onBackpressureBuffer()
.map<T>({ eventClass.cast(it) })
funpost(event:Any) = mBusSubject.onNext(event)
}

3. Create your event class eg

classEvent

4. Instantiate RxBus in onCreate of your application class with RxBus(AndroidSchedulers.mainThread())

5. Register the event and wait to consume them.

RxBus.register(Event::class.java)
.subscribe{ event ->// trigger something
}

6. Post an event with

RxBus.post(Event())

7. Be happy!!!