никак не найти ответа на два вопроса. Допустим из ретрофита к нам приходит 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) )
Заранее благодарю.
Кофе для программистов: как напиток влияет на продуктивность кодеров?
Рекламные вывески: как привлечь внимание и увеличить продажи
Стратегії та тренди в SMM - Технології, що формують майбутнє сьогодні
Выделенный сервер, что это, для чего нужен и какие характеристики важны?
Современные решения для бизнеса: как облачные и виртуальные технологии меняют рынок
Код очень объемный, из-за чего столкнулся с лимитом: The code of constructor Window(String) is exceeding the 65535 bytes limitМожно ли как-то увеличить этот лимит, если нет,...
У меня есть пользователь1 в бд, у которого есть эдакая репутацияКак сохранять то, что пользователь2 уже добавил репутацию пользователю1?