никак не найти ответа на два вопроса. Допустим из ретрофита к нам приходит Observable объект, вида что-то типа
private String id;
private List<String> list;
public List<String> getList(){return list};
Да, мы можем получить наш объект .subscribe(o->workWithObject(o)) где дальше достанем наш список, создадим observable и будем работать уже с ним Observable.fromIterable(ourObject.getList()). Вопрос в том, можно ли сделать элегантнее, то есть
retrofitService.get()
.subscribeOn(Schedulers.io())
.{вот например здесь достаем из нашего потока одного объекта массив и работаем уже с ним}
.take(10)
....
.observeOn(AndroidSchedulers.mainThread())
Надеюсь удалось объяснить.
Второй вопрос: также в rxjava2, как заменить каждый элемнт в потоке новым объектом. Например, есть map(s->s.toLowerCase()) а как сделать ( s-> new Smth(s) )
Заранее благодарю.
Апостиль в Лос-Анджелесе без лишних нервов и бумажной волокиты
Основные этапы разработки сайта для стоматологической клиники
Продвижение своими сайтами как стратегия роста и независимости