Skip to content
This repository was archived by the owner on Apr 20, 2018. It is now read-only.

Commit 0ef180b

Browse files
Adding new recipe to retrywhen
1 parent 70ba255 commit 0ef180b

1 file changed

Lines changed: 23 additions & 0 deletions

File tree

doc/api/core/operators/retrywhen.md

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,29 @@ var subscription = source.subscribe(
123123
// => Completed
124124
```
125125

126+
An incrememntal back-off strategy for handling errors:
127+
```js
128+
Rx.Observable.create(function (o) {
129+
console.log("subscribing");
130+
o.onError(new Error("always fails"));
131+
}).retryWhen(function (attempts) {
132+
return Rx.Observable.range(1, 3).zip(attempts, function (i) { return i; }).flatMap(function (i) {
133+
console.log("delay retry by " + i + " second(s)");
134+
return Rx.Observable.timer(i * 1000);
135+
});
136+
}).subscribe();
137+
138+
/*
139+
subscribing
140+
delay retry by 1 second(s)
141+
subscribing
142+
delay retry by 2 second(s)
143+
subscribing
144+
delay retry by 3 second(s)
145+
subscribing
146+
*/
147+
```
148+
126149
### Location
127150

128151
File:

0 commit comments

Comments
 (0)