Всем привет, не подскажите как через rxjs сделать последовательные запросы

Question

Всем привет, не подскажите как через rxjs сделать последовательные запросы

которые будут дожидаться ответа от сервера и только после этого отправлять новый,?
Стоит задача отправить на бэк более 10к обьектов, но за раз можно только 250, и теперь хочу кусками отправлять.

#angular #frontend #javascript #programming #russian

0

23.08.2023

15 ответов

9 просмотров

Alen Автор вопроса

Oleksandr 🤖
може тут не rxJs надо, а просто рекурсия? Если зап...

Спасибо за ответ, решил именно через Rxjs так как там очень грамотно реализована работа с потоками, не нужно париться на счет рекурсии и мемори лик. Решил простыми операторами from, bufferCount,concatMap первый держит в себе всю инфу второй принимает в себя размер или лимит отправляемых данных(250 в моем случае) третий уже выполняет отправку, дожидается ответа и снова отправляет новые данные если еще есть.

0

10 месяцев назад

Oleksandr 🤖

а когда упадет один из запросов, то скореей всего ведь цепочка вся отсновится? Давно делал подобную таску, то там пришлось дополнительно это обрабатывать, чтобы остальные запросы продолжали лететь

0

10 месяцев назад

Alen Автор вопроса

Oleksandr 🤖
а когда упадет один из запросов, то скореей всего ...

Возможно придется добавить catchError, честно говоря точно не знаю упадет ли весь цикл при первой ошибке, нужно будет затестить как нибудь.

0

10 месяцев назад

Oleksandr 🤖

Alen
Возможно придется добавить catchError, честно гово...

по-моему, я применил был concat вместо concatMap, чтобы избежать этой проблемы. У меня там дело было с пачкой платежей через страйп. И вот если какой-то платеж не прошел, то остальные не должны были прерваться... Что-такое. Ну это было больше года назад...

0

10 месяцев назад

Alen Автор вопроса

Oleksandr 🤖
по-моему, я применил был concat вместо concatMap, ...

Спасибо за совет, завтра попробую протестить.

0

10 месяцев назад

Leonid Симаков

Oleksandr 🤖
по-моему, я применил был concat вместо concatMap, ...

catchError, чтобы ошибка не полетела во внешний поток, можно ретрайнуть ещё сначала

0

10 месяцев назад

Alen Автор вопроса

Leonid Симаков
catchError, чтобы ошибка не полетела во внешний по...

Я правильно понял мой конкатмап это внутренний поток, и при добавке catchError я не допускаю прерывания внутреннего потока?

0

10 месяцев назад

Leonid Симаков

Alen
Я правильно понял мой конкатмап это внутренний пот...

Я не прям эксперт, но если не пустить ошибку выше с помощью catchError, то будет вызван по идее следующий concatMap

0

10 месяцев назад

Alen Автор вопроса

Leonid Симаков
Я не прям эксперт, но если не пустить ошибку выше ...

Окей, если что отпишусь завтра.

0

10 месяцев назад

Alen Автор вопроса

Leonid Симаков
Я не прям эксперт, но если не пустить ошибку выше ...

Эксперт не эксперт но в теории звучит очень логично😅

0

10 месяцев назад

Leonid Симаков

Alen
Эксперт не эксперт но в теории звучит очень логичн...

Ну внешний поток не должен упасть в таком случае, ошибку об работаете и замените на что-то, хоть даже EMPTY (просто сразу завершит внутренний поток с запросом в конкатмапе)

0

10 месяцев назад

xxtux Shvets

Alen
Возможно придется добавить catchError, честно гово...

если добавить кэтч после concatMap то поток не упадет, но завершится. кэтч нужно добавлять внутри concatMap, чтобы перехватить ошибку одного запроса и вместо него вернуть чтото

0

10 месяцев назад

Alen Автор вопроса

xxtux Shvets
если добавить кэтч после concatMap то поток не упа...

Внутри конкатмапа это .pipe() к нему прикрутить?

0

10 месяцев назад

Leonid Симаков

Alen
Внутри конкатмапа это .pipe() к нему прикрутить?

Да

0

10 месяцев назад

Oleksandr 🤖 · Accepted Answer

Oleksandr 🤖

може тут не rxJs надо, а просто рекурсия? Если запрос выполнился, то там еще раз вызывать тот же метод... хотя даже не рекурсия, а просто продолжать выполнять, пока массив есть

0

10 месяцев назад

169 похожих чатов

Всем привет, не подскажите как через rxjs сделать последовательные запросы

15 ответов

Похожие вопросы