Menggabungkan Dua atau lebih proses dengan Rx Java

Yoesuv 09.13 Android Tidak ada komentar

Seringkali dalam membuat aplikasi android terdapat dua atau lebih proses networking. nah, proses tersebut bisa digabung menjadi satu dengan operator pada Rx Java.

misal contoh seperti dibawah ini. dalam satu activity ada dua proses networking untuk mendapatkan data list dan gallery.

bagaimana cara menggabungkannya? yaitu bisa memakai operator flatMap dan concatMap. bedanya yaitu flatMap bersifat random dan concatMap kebalikannya yaitu berurutan. concatMap juga harus menunggu proses pertama selesai dahulu baru kemudian lanjut ke proses kedua.

contoh request dua networking dengan flatMap. berikut ini merupakan contoh fungsi/methodnya saja.
perhatikan appResponse.getListPlace() dan appResponse.getListGallery()

	fun getData() {
	isLoading.postValue(true)
	compositeDisposable.add(
	appResponse.getListPlace()
	.flatMap( object: Function<MutableList<PlaceModel>, ObservableSource<MutableList<GalleryModel>>> {
	override fun apply(t: MutableList<PlaceModel>): ObservableSource<MutableList<GalleryModel>> {
	Log.d(Constants.TAG_DEBUG,"MainViewModel # list place ${t.size}")
	listPlace.postValue(t)
	return appResponse.getListGallery()
	}
	})
	.observeOn(AndroidSchedulers.mainThread())
	.subscribeOn(Schedulers.io())
	.subscribe({ response ->
	Log.d(Constants.TAG_DEBUG,"MainViewModel # list gallery ${response.size}")
	isLoading.postValue(false)
	listGallery.postValue(response)
	},{ throwable ->
	isLoading.postValue(false)
	throwable.printStackTrace()
	})
	)
	}

view raw Network.kt hosted with ❤ by GitHub

jika ingin mencoba concatMap tinggal ganti saja operatornya dengan concatMap. selebihnya syntaxnya juga sama.

project ini menggunakan design pattern MVVM.

cek repository githubnya disini. (cek branch develop dan develop2)
selamat mencoba