Advertisement
Guest User

Untitled

a guest
Jan 19th, 2019
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.99 KB | None | 0 0
  1. private fun displayMonsterList(models: List<MonsterModel>) {
  2. compositeDisposable.add(
  3. models.toObservable()
  4. .subscribeOn(Schedulers.io())
  5. .doOnError { println(it) }
  6. .groupBy {
  7. it.getName(lang)
  8. }
  9. .flatmap { mapMonsterGroupToMultiMonster(it) }
  10. .observeOn(AndroidSchedulers.mainThread())
  11. .subscribeBy {
  12. println(it)
  13. }
  14. )
  15. }
  16.  
  17. private fun mapMonsterGroupToMultiMonster(group: GroupedObservable<String, MonsterModel>): MultiMonster {
  18. return Obervable
  19. .just(MultiMonster())
  20. .combinelatest(group,
  21. (result, model) -> {
  22. run(...);
  23. return result;
  24. })
  25. .lastelement()
  26. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement