ursus
05/31/2019, 5:02 PMPresenter {
val stateRelay = BehalviourRelay.createDefault(PresenterState())
val stateObservable: Observable<PresenterState>
get() = stateRelay
init {
disposables += coldApiRequest.
.subscribe { listOfData
stateRelay.accept { it.copy(listOfData = listOfData )}
}
}
fun onDestroy() {
disposables.clear()
}
}