blakelee
07/19/2017, 8:48 PMcompositeDisposable.add(api.getCoins(null, convert)
.map { it -> makeCoins(it, convert) } //Breaks here.
.subscribeOn(Schedulers.computation())
.observeOn(AndroidSchedulers.mainThread())
.subscribe ({ result ->
setTotal(result.size)
result.forEach { it.let { db.coinModel().insertCoin(it) }
async(UI) { lovelyProgressObservable.progress++ }
Log.i("RETROFIT", "Progress ${lovelyProgressObservable.progress}")
}
})
)
The map converts it from a JsonArray
to a MutableList<Coin>
. However the JsonArray gets garbage collected at element 47 every time. It retrieves all 900 something just fine. I'm using retrofit and it's returning an Observable<JsonArray>