代码之家 › 专栏 › 技术社区 › Noitidart

重复前面的可观察到的

rxjs

-1

Noitidart · 技术社区 · 6 年前

我有一个函数返回一个承诺。我想捕捉这个错误,然后指数式地等待更长的时间,然后重试。但现在我只是在等一个常数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

0 回复 | 直到 6 年前

kos 6 年前

要进行指数重试,您需要使用 retryWhen . 举个例子:

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

Try this code in a playground

在你的例子中你是重复 timer ,而不是 from(connectSocket()) . 所以替代 catchError 用一个得到你需要的东西。

希望这有帮助

此外,还有第三方工具可以添加指数退避,例如。
https://github.com/alex-okrushko/backoff-rxjs

看我的 "Error handling in RxJS"

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

9 月前

koque · 为什么我的RxJs主题没有按预期工作?

9 月前

Raphaël VO · 不使用Observable的初始值

9 月前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

1 年前

Lenni · 返回信号并在Angular中订阅它

1 年前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

1 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

1 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

1 年前