view-input-stream.kt

val inputSubject = PublishSubject.create<String>() // immutable!
val inputSubjectReadOnly = inputSubject.debounce(500L, TimeUnit.MILLISECONDS)
val someViewModel = SomeViewModel(inputSubjectReadOnly, ...)

override fun onSomeButtonClicked(...) {
     // process success/ failure, extract data
     inputSubject.onNext(data) // emit to input stream ViewModel consumes
}