Описание тега concatmap

Описание тега Вопросы с тегом
NoneConcat Map is a function from RxJava library, which returns a new Observable that emits items resulting from applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then emitting the items that result from concatinating those resulting Observables.
0 ответов

mock Наблюдаемая функция concatMap внутри модульного теста (Angular 5)

Редактировать: я понял, проблема в том, spyOn сделает функцию, которую он шпионит, чтобы вернуться undefined нужно позвонить and.callThough в явном виде. Я пытаюсь проверить мой компонент, который использует магазин ngrx. Я заглушаю свой магазин в э…
27 дек '17 в 08:41
3 ответа

RxJava flatMapIterable с concatMap

У меня есть 2 звонка для модернизации, которые мне нужны для A & B: (A): возвращает ArrayList (B): получает результат (A), который является ArrayList. (B) перебирает ArrayList и выполняет вызов дооснащения, используя каждый из них, и объединяет полу…
16 фев '17 в 08:22
1 ответ

onCompleted вызывается раньше, чем обрабатывается RxJava concatMap

У меня есть две наблюдаемые и использовал concatDelayError для последовательной обработки. Моя проблема в том, что onNext и onCompleted вызываются до обработки. Как я узнаю, что вся обработка завершена с помощью concatDelayError? Псудо-код: public O…
10 янв '18 в 09:01
1 ответ

.concatMap() запускает следующую наблюдаемую, но предыдущая не была закончена

Я использую RxJava на Android. У меня есть довольно простой кусок кода здесь: Observable> Observable = Observable.create((ObservableOnSubscribe<Observable<Boolean>>) emitter1 -> { emitter1.onNext(doSomething()); emitter1.onComplete();…
21 фев '18 в 11:49
2 ответа

Angular - RxJS ConcatMap - возвращает данные из обоих сервисных вызовов

Вероятно, это основной вопрос, но у меня есть приложение Angular, которое выполняет бэкэнд-вызов службы для извлечения некоторых данных, а затем использует эти данные для повторного вызова бэкэнд-службы. Второй вызов службы зависит от первого успешн…
16 июл '18 в 21:24
1 ответ

Как лучше всего выполнить вложенный concatMap для объединения нескольких таблиц?

На странице API concatMap на веб-сайте RethinkDB говорится, что eqJoin реализован с помощью concatMap + getAll, который должен обеспечивать лучшую производительность, чем другие объединения. в моем случае я хотел бы объединить несколько таблиц, вот …
19 сен '15 в 09:52
1 ответ

Странное поведение Rx.Observable.prototype.fromEvent()

Сегодня я видел странную проблему при использовании RxJS. Пожалуйста, помогите мне проверить это. Проблема, над которой я работаю: "Учитывая массив URL-адресов изображений, загрузите и добавьте все изображения в div". Все фрагменты кода для демонстр…
25 май '17 в 03:11
1 ответ

RxJava concatMap нет ответа

Надеюсь, у вас, ребята, все хорошо, я работаю над личным проектом Android, используя RxJava и Retrofit. Это поисковый запрос для проблем GitHub, я получаю информацию от пользователя, когда он нажимает кнопку поиска и использует PublishSubject объект…
19 май '17 в 17:31
1 ответ

ConcatMap прервался, когда ошибка в одной наблюдаемой

Я добавил свой код ниже `Observable.from(modifiedNodes) .concatMap(node => { return this.Model.setData(node); }) .subscribe( () => { NodeSaved++; }` Здесь, если setdata выдает ошибку для какого-либо промежуточного узла, следующая последователь…
06 июн '17 в 06:30
0 ответов

RxJava concatMap, который объединяет только самый последний выпуск

У меня есть система, которая синхронизирует данные удаленно, когда они меняются. Flowable испускает элементы, когда приходят новые данные, и я хочу обработать эти данные локально. Если Flowable испускает другой элемент во время обработки, я хочу под…
29 июл '18 в 21:28
2 ответа

Наблюдаемый concatMap делает вещи в главном потоке по некоторым причинам

У меня есть цепочка Observables и диалоговое окно, которое закрывается после того, как все закончено. Порядок такой: 1 вызов API получить ResponseBody 2 принять процесс тела ответа (не поток пользовательского интерфейса) 3 другой процесс (не поток п…
14 авг '16 в 09:53
0 ответов

Только первый элемент Flowable#concatMap в RxJava2 с наблюдаемым запуском запускается на конкретном планировщике

При использовании concatMap, как показано ниже, только первая выборка будет запущена из планировщика, все остальные вызовы выборки будут инициированы потоком обратного вызова предыдущей выборки.* fetch завершен асинхронный метод в другом потоке Flow…
04 окт '18 в 16:10
2 ответа

Повторяющиеся вызовы при использовании concatMap

Я хочу отобразить следующее предстоящее событие, на которое зарегистрирован пользователь. Для этого мне нужно сначала извлечь ближайшее событие (по времени), на которое зарегистрирован пользователь, а затем получить информацию об этом событии. Имеет…
31 май '17 в 19:21
1 ответ

Angular 6 + RxJs - обработка ошибок для concatMap

Я все еще изучаю RxJ и пытаюсь использовать concatMap(), чтобы НЕ использовать вложенные подписки. Я хочу, чтобы первый вызов был запущен, а затем задержался на секунду или две (создание записи в базе данных перед вторым запросом) перед выполнением …
01 мар '19 в 21:06
1 ответ

Как отправить запрос последовательно с проверками перед каждым запросом?

Я нуждаюсь: отправлять N запросов последовательно (для этого я использую concatMap) только если объект действителен (я расширяю карту concat кодом проверки) остановка очереди при первой ошибке (ответом на ошибку сервера или отклонением проверки клие…
16 ноя '18 в 10:05
1 ответ

Промежуточное решение RxJS FlatMap и ConcatMap?

У меня есть приложение, написанное на машинописном языке с использованием rxjs, где я использую flatMap, чтобы вернуть список из 5000 наблюдаемых, но я не хочу, чтобы все они были подписаны одновременно. Я попытался использовать concatMap, но это по…
20 дек '18 в 19:04
0 ответов

Android rxJava выполняет операции с результатами, полученными из Observable (map, flatMap, concatMap)

Возможный Дубликат RxJava, выполняющий операцию над списком и возвращающий наблюдаемое Я очень новичок в rxJava. Чего я хочу добиться - это получить данные из базы данных как ArrayList и выполнить некоторые операции с каждым элементом ArrayList, Я х…
11 фев '18 в 17:05
1 ответ

RxJava - flatmap vs concatMap - почему порядок подписки такой же?

В соответствии с этим потоком conCatMap и flatmap отличаются только порядком, в котором отправляются элементы. Поэтому я сделал тест и создал простой поток целых чисел и хотел посмотреть, в каком порядке они будут выбрасываться. Я сделал небольшую з…
21 мар '16 в 13:11
0 ответов

Последовательность HTTP-запросов в Angular 6 с RxJS

Моя цель - сохранить информацию на бэкэнд-сервере с помощью POST-запросов. Мне нужно, чтобы эти запросы выполнялись один за другим по завершении предыдущего. Но мне нужно добавить немного логики между запросами. Эти запросы выполняются с использован…
29 дек '18 в 08:39
7 ответов

В чем разница между concatMap и flatMap в RxJava

Кажется, что эти 2 функции очень похожи. Они имеют одинаковую подпись (принимая rx.functions.Func1<? super T, ? extends Observable<? extends R>> func), и их мраморные диаграммы выглядят точно так же. Не могу вставить здесь фотографии, но…
04 июл '14 в 09:51