maxost

data class Sms(val phone: String, val text: String)

object SmsBus {
    private val bus by lazy { PublishSubject.create<Sms>() }

    fun incomingSms(): Observable<Sms> = bus
    fun postSms(sms: Sms) = bus.onNext(sms)
}