adrielcafe/kbus

Dead simple EventBus for Android made with Kotlin and RxJava 2

KBus

Super lightweight (13 LOC) and minimalistic (post(), subscribe(), unsubscribe()) EventBus written with idiomatic Kotlin and RxJava 2

KBus in 3 steps

1. Define your events

// With data
data class ShowMessageEvent(val message: String)

// Without data
class OtherEvent

2. Add subscribers

override fun onStart() {
    super.onStart()
    KBus.subscribe<ShowMessageEvent>(this) {
        showMessage(it.message)
    }
    KBus.subscribe<OtherEvent>(this) {
        doSomething()
    }
}

override fun onStop() {
    super.onStop()
    KBus.unsubscribe(this)
}

Where:

• ShowMessageEvent - the event you're subscribing
• this - the subscriber (by default the current Activity/Fragment)
• { showMessage() } - the subscription observer
• it - the event instance

Sticky events

If you want to post events between Activities/Fragments just subscribe in onCreate() (or onPostCreate()) and unsubscribe in onDestroy()

override fun onPostCreate(savedInstanceState: Bundle?) {
    super.onPostCreate(savedInstanceState)
    KBus.subscribe<ShowMessageEvent>(this) {
        showMessage(it.message)
    }
}

override fun onDestroy() {
    super.onDestroy()
    KBus.unsubscribe(this)
}

3. Post events

KBus.post(ShowMessageEvent("Hello KBus!"))

Add KBus to your project

repositories {
    maven { url "https://jitpack.io" }
}

dependencies {
    implementation 'io.reactivex.rxjava2:rxjava:2.2.10'
    implementation 'com.github.adrielcafe:KBus:1.1'
}

kbus's Issues

KT and Java mixed code in the same project

I have kt and Java mixed in the same project.
I send messages to bus from KT

How do I receive messages in Java part of the project?
Some lines of code would be useful

How to handle error with the subscriber

Hi, how can we handle the error in the subscriber?
Can you give an example.

Thank you.

problem implementing

hi, sorry if this is an obvious question, i'm only a sprout with android. i was trying to implement your library in my project as you suggest, adding a few lines in my build.gradle (after copying "library" folder from KBus-master to my project "lib" folder):

    implementation 'io.reactivex.rxjava2:rxjava:2.2.10'
    implementation 'com.github.adrielcafe:KBus:1.1'

also tried

implementation 'com.github.adrielcafe:KBus:1.0'

as this is the version github is reporting, yet to no avail. it tells me dependency cannot be resolved. what am i missing?

--
using AndroidStudio 3.5.2