rxmvp

rxmvp.kt

interface Model {
  fun first10Users(): Observable<List<Data>>
}

interface View {
  fun displayUserList(users: List<Data>)
  fun backButtonClicks(): Observable<ClickEvent>
}

class Presenter {
  @Inject
  lateinit var model: Model
  
  @Inject
  lateinit var view: View
  
  /* injection */
  
  fun setup() {
    model.first10Users()
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe { view.displayUserList(it) }
    
    view.backButtonClicks()
      .debounce(1000)
      .subscribe { dismiss() }
  }
}