rxjava-combined-api-call-example

rxjava-combined-api-call-example.kt

private fun fetchAccounts() {
    val externalAccountLinkStatusObservable = linkCoordinator.linkStatusObservable
    val wealthFrontAccountObservable = accountRepository.wealthfrontAccountObservable
    val wealthFrontAccountRequestsObservable = accountRequestsRepository.wealthfrontAccountRequestObservable
    val calloutObservable = calloutsRepository.getCalloutsObservable(AccountListSection::class.java)
    
    autoDisposer.autoDispose(
        combineLatest(
            externalAccountLinkStatusObservable,
            wealthFrontAccountObservable,
            wealthFrontAccountRequestsObservable,
            calloutObservable
        ) { parallelLinkingResult, abstractAccountOverviews, accountRequests, callouts ->
            showAccounts(abstractAccountOverviews, accountRequests, parallelLinkingResult.statuses, callouts)
        }
        .doOnSubscribe { view?.showTransparentLoading() }
        .subscribe(
            {
                view?.hideLoadingAndErrorStates()
            },
            {
                view?.hideLoadingAndErrorStates()
                networkErrorToaster.showErrorMessage(it, R.string.dashboard_load_error)
            }
        )
    )
}