diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/operators/retryWhen.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm/internal/operators/retryWhen.js | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/operators/retryWhen.js b/node_modules/rxjs/dist/esm/internal/operators/retryWhen.js new file mode 100644 index 0000000..cda09f2 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/operators/retryWhen.js @@ -0,0 +1,30 @@ +import { innerFrom } from '../observable/innerFrom'; +import { Subject } from '../Subject'; +import { operate } from '../util/lift'; +import { createOperatorSubscriber } from './OperatorSubscriber'; +export function retryWhen(notifier) { + return operate((source, subscriber) => { + let innerSub; + let syncResub = false; + let errors$; + const subscribeForRetryWhen = () => { + innerSub = source.subscribe(createOperatorSubscriber(subscriber, undefined, undefined, (err) => { + if (!errors$) { + errors$ = new Subject(); + innerFrom(notifier(errors$)).subscribe(createOperatorSubscriber(subscriber, () => innerSub ? subscribeForRetryWhen() : (syncResub = true))); + } + if (errors$) { + errors$.next(err); + } + })); + if (syncResub) { + innerSub.unsubscribe(); + innerSub = null; + syncResub = false; + subscribeForRetryWhen(); + } + }; + subscribeForRetryWhen(); + }); +} +//# sourceMappingURL=retryWhen.js.map
\ No newline at end of file |