Повторите предыдущую наблюдаемую

Question

У меня есть функция, которая возвращает обещание. Я хочу поймать ошибку на этом, а затем экспоненциально подождать и повторить попытку. Но сейчас я просто жду константу 5 с. Вот мой код:

from(connectSocket()).pipe(
    catchError(e => {
        console.log('got error!', e.message);
        return timer(5000).pipe(
            tap(() => console.log('will repeat connect now')),
            repeat(1)
        );
    }),
    tap(() => setIsConnected.next(true))
);

Однако это не повторяется.

Мой полный код находится в этой песочнице - https://stackblitz.com/edit/rxjs-g7msgv?file=index.ts

Answer 1

Чтобы сделать экспоненциальную повторную попытку, вам нужно использовать retryWhen.Вот пример:

// will retry with
// 0, 10, 40, 90, 160 ms delays
retryWhen(error$ =>
  error$.pipe(
    delayWhen((_, i) => timer(i * i * 10))
  )
)

Попробуйте этот код на детской площадке

В вашем примере вы повторяете timer вместо повтор from(connectSocket()).Поэтому замените catchError на retryWhen, чтобы получить то, что вам нужно.

Надеюсь, это поможет

-

Кроме того, существуют сторонние инструменты для добавления экспоненциального отката.Например,
https://github.com/alex-okrushko/backoff-rxjs

См. мою статью "Обработка ошибок в RxJS" , чтобы лучше понять ошибки и повторы в RxJS.