SDK Function for fetching encounters from server and storing them locally

EncounterRepository.kt

fun getAllEncountersByPatientUuidAndSaveLocally(uuid: String): Observable<List<Encounter>> {
        val encounterList: MutableList<Encounter> = mutableListOf()
        if (!NetworkUtils.isOnline()) throw Exception("Must be online to fetch encounters")

        restApi.getAllEncountersForPatientByPatientUuid(uuid).execute().run {
            if (isSuccessful && this.body() != null) {

                val encounterResources: List<Resource> = this.body()!!.results
                for (encounterResource in encounterResources) {
                    getEncounterByUuid(encounterResource.uuid!!).subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe(
                            { encounter ->
                                encounterList.add(encounter)
                            },
                            { error ->
                                Log.e("Encounter Repository", "Error: ${error.message}")
                            },
                            {
                                Log.d("Encounter Repository", "Observable completed")
                            }
                        )
                }
                encounterDAO.deleteAllStandaloneEncounters(uuid)      //delete previous list
                encounterDAO.saveStandaloneEncounters(encounterList) //save latest list
                return Observable.just(encounterList.toList())
            } else {
                throw Exception("Get Encounters error: ${message()}")
            }
        }
    }