Hey guys, I'm having some issues with a db call. I have this:

hdb.getHoldingsOrderId()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(<http://Schedulers.io|Schedulers.io>())
            .concatMapEager { items -> Flowable.fromIterable(items).flatMap(this::mergeTransactions) }
            .toList()

fun mergeTransactions(holdings: Holdings) =
        tdb.getTransactionsById(holdings.id)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(<http://Schedulers.io|Schedulers.io>())
                .doOnNext { holdings.transaction = it }
                .map { holdings }

If I take away the concatMapEager and toList of the first one, it returns the database items just fine. However, I need to make another db call to get the rest of the members which is where the concatMapEager comes in. The second function appears to work just fine, but the place where I subscribe for the first method never emits anything.