Typical Room RxJava read stream and presentation of data

room-rxjava-read-render.kt

schoolDAO.getData() // Flowable
                .subscribeOn(schedulerProvider.io())
                .doOnSubscribe { showProgressSpinner() }
                .flatMapSingle { school -> getExtraData(school) }
                .observeOn(schedulerProvider.ui())
                .subscribe({ data ->
                    hideProgressSpinner()
                    updateUi(data)
                }, { throwable ->
                    hideProgressSpinner()
                    handleError(throwable)
                })