Size: a a a

ReactiveX - русскоговорящее сообщество

2017 March 03

GR

Grigory Rylov in ReactiveX - русскоговорящее сообщество
Artem Gilmudinov
а у тебя не Single там?
нет Observable<List<Data>>
источник

AD

Andrew Dementiev in ReactiveX - русскоговорящее сообщество
Artur
Репозиторий возвращает сингл с листом. Я хочу из этого сингла вытащить элементы и проэмитить в observable. Как это можно сделать? RxJava2
yourStuff.flatMap(Observable::from)
источник

A

Artur in ReactiveX - русскоговорящее сообщество
источник

A

Artur in ReactiveX - русскоговорящее сообщество
Предлагает  MaybeSource  исходя из того, что происходит ниже?
источник

AD

Andrew Dementiev in ReactiveX - русскоговорящее сообщество
yourListObservable.flatMap(new Func1<List<Car>, Observable<Car>>() {
   @Override
   public Observable<Car> call(List<Car> iterable) {
       return Observable.from(iterable);
   }
})
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Для начала давай определимся, до флетмапа там идет обсервабле или мейби? Потому что это разные объекты, и неявно один в другой не могут быть сконвертированы.
источник

A

Artur in ReactiveX - русскоговорящее сообщество
Спасибо. У меня немного другой случай, так не работает.
источник

A

Artur in ReactiveX - русскоговорящее сообщество
Андрей
Для начала давай определимся, до флетмапа там идет обсервабле или мейби? Потому что это разные объекты, и неявно один в другой не могут быть сконвертированы.
Да там вообще такой финт ушами происходит...) Сейчас ещё потыкаюсь, если что, гист скину.
источник

A

Artur in ReactiveX - русскоговорящее сообщество
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Observable.reduce возвращает Maybe
источник

A

Artur in ReactiveX - русскоговорящее сообщество
В метод приходит обсёрвабл с контактами, считанными с телефона.
Я их кеширую, потом составляю строку вида "имятелефонимятелефон", по которой считаю хэш. Если хэш не совпадает с тем, который был записан ранее, мне нужно отправить этот список телефонов на сервер.
Maybe.FromSingle() мне пришло сделать после фильтра, насколько я помню.
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Если нужно снова в обсервабле конвертнуть, то перед флетмепом сделай .toObservable()
источник

A

Artur in ReactiveX - русскоговорящее сообщество
Насколько вообще нормальная практика прыгать между этими типами в цепочке? Репозиторий возвращает SIngle с листом, потом его конвертить в Observable с конретными элементами и т.д.?

Спасибо, что-то туплю.
источник

A

Artur in ReactiveX - русскоговорящее сообщество
Есть какие-то аргмументы насчёт того, использовать ли .toObservable().flatMap() или сразу .flatMapObservable() ?
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
юзай  .flatMapObservable(). Разницы реально никакой  https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/Maybe.java#L2752 , но при чтении кода конвертация именно через flatMap более явная
источник

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
Хочу, чтобы приложение падало в onError с более-менее нормальным стеком, по которому можно было бы определить причину. Как в этом случае лучше поступать? Просто не добавлять observable на onError?
источник

VB

Victor Babenko in ReactiveX - русскоговорящее сообщество
throw e;
источник

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
в стеке - каша
источник

VB

Victor Babenko in ReactiveX - русскоговорящее сообщество
а ошибка точно через onError проходит?
источник

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
ну да, куда ей ещё
источник