Как обрабатывать избыточные запросы и повторять попытки и сортировку в MergeMap

Question

У меня есть фрагмент кода, который обрабатывает concurrent запросы к серверу, вопрос в том, что я не могу остановить mergeMap до того, как он сделает избыточные вызовы Http .

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

Как сохранить порядок и при этом быть параллельным?

from(observableQueries)
            .pipe(
                mergeMap(partialQuery => {
                    return this.messageService.getResults(partialQuery, true);
                }, 4),
                takeWhile((res: MessagesResult) => {
                    moreResults = res.isMoreResults;
                    return shouldContinue;
                }),
                catchError((err, caught) => {
                    return this.handleError(err);
                })
            )