Closed ganghee closed 5 years ago
compositeDisposable.add(
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map {
it.map {
it.market
}.joinToString(",")
}
.subscribe({
jsonApi.getTickers(it)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map {
it.filter{
it.market.split("-")[0] == firstMarket
}
}
.subscribe({
displayData(it)
}, {
})
}, {
Toast.makeText(context, it.message, Toast.LENGTH_LONG).show()
})
)