Size: a a a

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

2020 September 01

v

vitaly in ReactiveX - русскоговорящее сообщество
нет, в своём флетмаке, куда приходит лист
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Single.just(list).flatMapObservable(Observable::fromIterable)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Вот примерно разобрался
источник

S

Singular in ReactiveX - русскоговорящее сообщество
insert это Completable
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Короче, тебе нужно либо работать со списком, это линейная херня, можно прям внутри папа или ылетмапа взять из списка нужный элемент (и странно, что тебе это не пришло в голову, если нужно именно это), либо разложить список на элементы, которые последовательно полетят в пайплайне, это тот вариант, что предложил я. Тогда можно будет сделать .filter { filter(it) }.firstOrError()
источник

S

Singular in ReactiveX - русскоговорящее сообщество
А мне надо it перебросить через flatMap
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Тогда делай внутри
источник

i

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

S

Singular in ReactiveX - русскоговорящее сообщество
iamthevoid
Короче, тебе нужно либо работать со списком, это линейная херня, можно прям внутри папа или ылетмапа взять из списка нужный элемент (и странно, что тебе это не пришло в голову, если нужно именно это), либо разложить список на элементы, которые последовательно полетят в пайплайне, это тот вариант, что предложил я. Тогда можно будет сделать .filter { filter(it) }.firstOrError()
Я прям в мапе юзал через foreach, но эт хрень
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Single.just(list).flatMap { insert(it).toSingle {it}}
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Я вообще вот так делал
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Нее, так не надо, лучше сразу списком вставлять, эта штука может работать как магия, если там какие то шедулеры
источник

S

Singular in ReactiveX - русскоговорящее сообщество
iamthevoid
Single.just(list).flatMap { insert(it).toSingle {it}}
так нельзя. insert принимает Item, а тут ты List передаешь
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Зафлетмапь на комплитабл, который внутри флетмапа флетмапится в сингл
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Singular
так нельзя. insert принимает Item, а тут ты List передаешь
Сделай, чтобы принимал лист
источник

S

Singular in ReactiveX - русскоговорящее сообщество
iamthevoid
Сделай, чтобы принимал лист
В этом и беда
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Если не реально, то через флетМепИтерейбл
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Singular
Вот примерно разобрался
через flatMapobsrvable не получится, так как он вощврщяет Complateble
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Single.just(list).flatMap { Observable.flatMapIterable(it).concatMapSingle { insert(it).and then(Single.just(it))}.toList()  }
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Всё получится, нужно просто сделать правильные вещи в правильном месте
источник