```fun getHoldings() = hdb.getHoldingsOrderId() ...
# rx
b
Copy code
fun getHoldings() = hdb.getHoldingsOrderId()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(<http://Schedulers.io|Schedulers.io>())
            .take(1)
            .concatMap { items -> Flowable.fromIterable(items) }
            .concatMap { item ->
                tdb.getTransactionsById(item.id)
                        .take(1)
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribeOn(<http://Schedulers.io|Schedulers.io>())
                        .map {
                            item.transaction = it
                            item
                        }
            }
            .toList()