blakelee
08/29/2017, 8:37 PMfun 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()