{"dependencies":[{"name":"../observable/innerFrom","data":{"asyncType":null,"isESMImport":false,"locs":[{"start":{"line":4,"column":18,"index":123},"end":{"line":4,"column":52,"index":157}}],"key":"T4CuDoHB9q4c1mpqb7scn7763KE=","exportNames":["*"],"imports":1}},{"name":"../Subject","data":{"asyncType":null,"isESMImport":false,"locs":[{"start":{"line":5,"column":16,"index":175},"end":{"line":5,"column":37,"index":196}}],"key":"rCTmTYO6TJ25UVDxGzxJlC7LYfM=","exportNames":["*"],"imports":1}},{"name":"../util/lift","data":{"asyncType":null,"isESMImport":false,"locs":[{"start":{"line":6,"column":13,"index":211},"end":{"line":6,"column":36,"index":234}}],"key":"QCxE0PdfaUm4cT9qPVYaaaoo46A=","exportNames":["*"],"imports":1}},{"name":"./OperatorSubscriber","data":{"asyncType":null,"isESMImport":false,"locs":[{"start":{"line":7,"column":27,"index":263},"end":{"line":7,"column":58,"index":294}}],"key":"5a4JxA+rxI0MIxewBKZddpWmHrQ=","exportNames":["*"],"imports":1}}],"output":[{"data":{"code":"__d(function (global, require, _$$_IMPORT_DEFAULT, _$$_IMPORT_ALL, module, exports, _dependencyMap) {\n  \"use strict\";\n\n  Object.defineProperty(exports, \"__esModule\", {\n    value: true\n  });\n  exports.retryWhen = void 0;\n  var innerFrom_1 = require(_dependencyMap[0], \"../observable/innerFrom\");\n  var Subject_1 = require(_dependencyMap[1], \"../Subject\");\n  var lift_1 = require(_dependencyMap[2], \"../util/lift\");\n  var OperatorSubscriber_1 = require(_dependencyMap[3], \"./OperatorSubscriber\");\n  function retryWhen(notifier) {\n    return lift_1.operate(function (source, subscriber) {\n      var innerSub;\n      var syncResub = false;\n      var errors$;\n      var _subscribeForRetryWhen = function subscribeForRetryWhen() {\n        innerSub = source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, undefined, undefined, function (err) {\n          if (!errors$) {\n            errors$ = new Subject_1.Subject();\n            innerFrom_1.innerFrom(notifier(errors$)).subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function () {\n              return innerSub ? _subscribeForRetryWhen() : syncResub = true;\n            }));\n          }\n          if (errors$) {\n            errors$.next(err);\n          }\n        }));\n        if (syncResub) {\n          innerSub.unsubscribe();\n          innerSub = null;\n          syncResub = false;\n          _subscribeForRetryWhen();\n        }\n      };\n      _subscribeForRetryWhen();\n    });\n  }\n  exports.retryWhen = retryWhen;\n});","lineCount":40,"map":[[2,2,1,0],[2,14,1,12],[4,2,2,0,"Object"],[4,8,2,6],[4,9,2,7,"defineProperty"],[4,23,2,21],[4,24,2,22,"exports"],[4,31,2,29],[4,33,2,31],[4,45,2,43],[4,47,2,45],[5,4,2,47,"value"],[5,9,2,52],[5,11,2,54],[6,2,2,59],[6,3,2,60],[6,4,2,61],[7,2,3,0,"exports"],[7,9,3,7],[7,10,3,8,"retryWhen"],[7,19,3,17],[7,22,3,20],[7,27,3,25],[7,28,3,26],[8,2,4,0],[8,6,4,4,"innerFrom_1"],[8,17,4,15],[8,20,4,18,"require"],[8,27,4,25],[8,28,4,25,"_dependencyMap"],[8,42,4,25],[8,72,4,51],[8,73,4,52],[9,2,5,0],[9,6,5,4,"Subject_1"],[9,15,5,13],[9,18,5,16,"require"],[9,25,5,23],[9,26,5,23,"_dependencyMap"],[9,40,5,23],[9,57,5,36],[9,58,5,37],[10,2,6,0],[10,6,6,4,"lift_1"],[10,12,6,10],[10,15,6,13,"require"],[10,22,6,20],[10,23,6,20,"_dependencyMap"],[10,37,6,20],[10,56,6,35],[10,57,6,36],[11,2,7,0],[11,6,7,4,"OperatorSubscriber_1"],[11,26,7,24],[11,29,7,27,"require"],[11,36,7,34],[11,37,7,34,"_dependencyMap"],[11,51,7,34],[11,78,7,57],[11,79,7,58],[12,2,8,0],[12,11,8,9,"retryWhen"],[12,20,8,18,"retryWhen"],[12,21,8,19,"notifier"],[12,29,8,27],[12,31,8,29],[13,4,9,4],[13,11,9,11,"lift_1"],[13,17,9,17],[13,18,9,18,"operate"],[13,25,9,25],[13,26,9,26],[13,36,9,36,"source"],[13,42,9,42],[13,44,9,44,"subscriber"],[13,54,9,54],[13,56,9,56],[14,6,10,8],[14,10,10,12,"innerSub"],[14,18,10,20],[15,6,11,8],[15,10,11,12,"syncResub"],[15,19,11,21],[15,22,11,24],[15,27,11,29],[16,6,12,8],[16,10,12,12,"errors$"],[16,17,12,19],[17,6,13,8],[17,10,13,12,"subscribeForRetryWhen"],[17,32,13,33],[17,35,13,36],[17,44,13,12,"subscribeForRetryWhen"],[17,65,13,33,"subscribeForRetryWhen"],[17,66,13,33],[17,68,13,48],[18,8,14,12,"innerSub"],[18,16,14,20],[18,19,14,23,"source"],[18,25,14,29],[18,26,14,30,"subscribe"],[18,35,14,39],[18,36,14,40,"OperatorSubscriber_1"],[18,56,14,60],[18,57,14,61,"createOperatorSubscriber"],[18,81,14,85],[18,82,14,86,"subscriber"],[18,92,14,96],[18,94,14,98,"undefined"],[18,103,14,107],[18,105,14,109,"undefined"],[18,114,14,118],[18,116,14,120],[18,126,14,130,"err"],[18,129,14,133],[18,131,14,135],[19,10,15,16],[19,14,15,20],[19,15,15,21,"errors$"],[19,22,15,28],[19,24,15,30],[20,12,16,20,"errors$"],[20,19,16,27],[20,22,16,30],[20,26,16,34,"Subject_1"],[20,35,16,43],[20,36,16,44,"Subject"],[20,43,16,51],[20,44,16,52],[20,45,16,53],[21,12,17,20,"innerFrom_1"],[21,23,17,31],[21,24,17,32,"innerFrom"],[21,33,17,41],[21,34,17,42,"notifier"],[21,42,17,50],[21,43,17,51,"errors$"],[21,50,17,58],[21,51,17,59],[21,52,17,60],[21,53,17,61,"subscribe"],[21,62,17,70],[21,63,17,71,"OperatorSubscriber_1"],[21,83,17,91],[21,84,17,92,"createOperatorSubscriber"],[21,108,17,116],[21,109,17,117,"subscriber"],[21,119,17,127],[21,121,17,129],[21,133,17,141],[22,14,18,24],[22,21,18,31,"innerSub"],[22,29,18,39],[22,32,18,42,"subscribeForRetryWhen"],[22,54,18,63],[22,55,18,64],[22,56,18,65],[22,59,18,69,"syncResub"],[22,68,18,78],[22,71,18,81],[22,75,18,86],[23,12,19,20],[23,13,19,21],[23,14,19,22],[23,15,19,23],[24,10,20,16],[25,10,21,16],[25,14,21,20,"errors$"],[25,21,21,27],[25,23,21,29],[26,12,22,20,"errors$"],[26,19,22,27],[26,20,22,28,"next"],[26,24,22,32],[26,25,22,33,"err"],[26,28,22,36],[26,29,22,37],[27,10,23,16],[28,8,24,12],[28,9,24,13],[28,10,24,14],[28,11,24,15],[29,8,25,12],[29,12,25,16,"syncResub"],[29,21,25,25],[29,23,25,27],[30,10,26,16,"innerSub"],[30,18,26,24],[30,19,26,25,"unsubscribe"],[30,30,26,36],[30,31,26,37],[30,32,26,38],[31,10,27,16,"innerSub"],[31,18,27,24],[31,21,27,27],[31,25,27,31],[32,10,28,16,"syncResub"],[32,19,28,25],[32,22,28,28],[32,27,28,33],[33,10,29,16,"subscribeForRetryWhen"],[33,32,29,37],[33,33,29,38],[33,34,29,39],[34,8,30,12],[35,6,31,8],[35,7,31,9],[36,6,32,8,"subscribeForRetryWhen"],[36,28,32,29],[36,29,32,30],[36,30,32,31],[37,4,33,4],[37,5,33,5],[37,6,33,6],[38,2,34,0],[39,2,35,0,"exports"],[39,9,35,7],[39,10,35,8,"retryWhen"],[39,19,35,17],[39,22,35,20,"retryWhen"],[39,31,35,29],[40,0,35,30],[40,3]],"functionMap":{"names":["<global>","retryWhen","lift_1.operate$argument_0","subscribeForRetryWhen","OperatorSubscriber_1.createOperatorSubscriber$argument_3","OperatorSubscriber_1.createOperatorSubscriber$argument_1"],"mappings":"AAA;ACO;0BCC;oCCI;wHCC;iICG;qBDE;aDK;SDO;KDE;CDC"},"hasCjsExports":true},"type":"js/module"}]}