{"version":3,"file":"rx.backpressure.min.js","sources":["rx.backpressure.js"],"names":["factory","objectTypes","boolean","function","object","number","string","undefined","root","window","this","freeExports","exports","nodeType","freeModule","module","freeGlobal","global","define","amd","Rx","require","call","exp","combineLatestSource","source","subject","resultSelector","AnonymousObservable","observer","next","x","i","values","res","hasValue","hasValueAll","every","identity","err","onError","apply","ex","onNext","isDone","onCompleted","Array","CompositeDisposable","subscribe","e","bind","Observable","observableProto","prototype","AbstractObserver","internals","Subject","Observer","disposableEmpty","Disposable","empty","disposableCreate","create","inherits","addProperties","timeoutScheduler","Scheduler","timeout","currentThread","helpers","PausableObservable","__super__","conn","publish","subscription","connection","pausable","pauser","distinctUntilChanged","b","connect","dispose","controller","merge","pause","resume","PausableBufferedObservable","previousShouldFire","q","startWith","data","shouldFire","results","length","shift","push","pausableBuffered","ControlledObservable","enableQueue","ControlledSubject","multicast","refCount","request","numberOfItems","queue","requestedCount","requestedDisposable","error","hasFailed","hasCompleted","controlledDisposable","value","hasRequested","disposeCurrentRequest","_processRequest","returnValue","self","r","controlled","StopAndWaitObservable","StopAndWaitObserver","schedule","__sub__","observable","cancel","stopAndWaitObserverProto","completed","stopAndWait","WindowedObservable","WindowedObserver","windowSize","received","windowedObserverPrototype","windowed"],"mappings":";CAEE,SAAUA,GACR,GAAIC,IACAC,WAAW,EACXC,YAAY,EACZC,QAAU,EACVC,QAAU,EACVC,QAAU,EACVC,WAAa,GAGbC,EAAQP,QAAmBQ,UAAWA,QAAWC,KACjDC,EAAcV,QAAmBW,WAAYA,UAAYA,QAAQC,UAAYD,QAC7EE,EAAab,QAAmBc,UAAWA,SAAWA,OAAOF,UAAYE,OAEzEC,GADgBF,GAAcA,EAAWF,UAAYD,GAAeA,EACvDV,QAAmBgB,UAAWA,SAE3CD,GAAeA,EAAWC,SAAWD,GAAcA,EAAWP,SAAWO,IACzER,EAAOQ,GAIW,kBAAXE,SAAyBA,OAAOC,IACvCD,QAAQ,MAAO,SAAUE,EAAIR,GACzB,MAAOZ,GAAQQ,EAAMI,EAASQ,KAET,gBAAXL,SAAuBA,QAAUA,OAAOH,UAAYD,EAClEI,OAAOH,QAAUZ,EAAQQ,EAAMO,OAAOH,QAASS,QAAQ,SAEvDb,EAAKY,GAAKpB,EAAQQ,KAAUA,EAAKY,MAEvCE,KAAKZ,KAAM,SAAUF,EAAMe,EAAKH,EAAIb,GA+EpC,QAASiB,GAAoBC,EAAQC,EAASC,GAC5C,MAAO,IAAIC,GAAoB,SAAUC,GAOvC,QAASC,GAAKC,EAAGC,GACfC,EAAOD,GAAKD,CACZ,IAAIG,EAEJ,IADAC,EAASH,IAAK,EACVI,IAAgBA,EAAcD,EAASE,MAAMC,IAAY,CAC3D,GAAIC,EAEF,WADAV,GAASW,QAAQD,EAInB,KACEL,EAAMP,EAAec,MAAM,KAAMR,GACjC,MAAOS,GAEP,WADAb,GAASW,QAAQE,GAGnBb,EAASc,OAAOT,GAEdU,GAAUX,EAAO,IACnBJ,EAASgB,cAzBb,GAIEN,GAJEJ,IAAY,GAAO,GACrBC,GAAc,EACdQ,GAAS,EACTX,EAAS,GAAIa,OAAM,EA0BrB,OAAO,IAAIC,GACTtB,EAAOuB,UACL,SAAUjB,GACRD,EAAKC,EAAG,IAEV,SAAUkB,GACJhB,EAAO,GACTJ,EAASW,QAAQS,GAEjBV,EAAMU,GAGV,WACEL,GAAS,EACTX,EAAO,IAAMJ,EAASgB,gBAE1BnB,EAAQsB,UACN,SAAUjB,GACRD,EAAKC,EAAG,IAEVF,EAASW,QAAQU,KAAKrB,GACtB,WACEe,GAAS,EACTd,GAAK,EAAM,OAGhBL,GArIL,GAAI0B,GAAa/B,EAAG+B,WAClBC,EAAkBD,EAAWE,UAC7BzB,EAAsBR,EAAGQ,oBACzB0B,EAAmBlC,EAAGmC,UAAUD,iBAChCP,EAAsB3B,EAAG2B,oBACzBS,EAAUpC,EAAGoC,QACbC,EAAWrC,EAAGqC,SACdC,EAAkBtC,EAAGuC,WAAWC,MAChCC,EAAmBzC,EAAGuC,WAAWG,OACjCC,EAAW3C,EAAGmC,UAAUQ,SACxBC,EAAgB5C,EAAGmC,UAAUS,cAC7BC,EAAmB7C,EAAG8C,UAAUC,QAEhC7B,GADyBlB,EAAG8C,UAAUE,cAC3BhD,EAAGiD,QAAQ/B,UAKpBgC,EAAsB,SAAUC,GAIlC,QAASvB,GAAUnB,GACjB,GAAI2C,GAAO9D,KAAKe,OAAOgD,UACrBC,EAAeF,EAAKxB,UAAUnB,GAC9B8C,EAAajB,EAEXkB,EAAWlE,KAAKmE,OAAOC,uBAAuB9B,UAAU,SAAU+B,GAChEA,EACFJ,EAAaH,EAAKQ,WAElBL,EAAWM,UACXN,EAAajB,IAIjB,OAAO,IAAIX,GAAoB2B,EAAcC,EAAYC,GAG3D,QAASN,GAAmB7C,EAAQoD,GAClCnE,KAAKe,OAASA,EACdf,KAAKwE,WAAa,GAAI1B,GAGpB9C,KAAKmE,OADHA,GAAUA,EAAO7B,UACLtC,KAAKwE,WAAWC,MAAMN,GAEtBnE,KAAKwE,WAGrBX,EAAUjD,KAAKZ,KAAMsC,EAAWvB,GAWlC,MAxCAsC,GAASO,EAAoBC,GAgC7BD,EAAmBjB,UAAU+B,MAAQ,WACnC1E,KAAKwE,WAAWvC,QAAO,IAGzB2B,EAAmBjB,UAAUgC,OAAS,WACpC3E,KAAKwE,WAAWvC,QAAO,IAGlB2B,GAEPnB,EAUFC,GAAgBwB,SAAW,SAAUC,GACnC,MAAO,IAAIP,GAAmB5D,KAAMmE,GA+DtC,IAAIS,GAA8B,SAAUf,GAI1C,QAASvB,GAAUnB,GACjB,GAAY0D,GAARC,KAEAd,EACFlD,EACEd,KAAKe,OACLf,KAAKmE,OAAOC,uBAAuBW,WAAU,GAC7C,SAAUC,EAAMC,GACd,OAASD,KAAMA,EAAMC,WAAYA,KAElC3C,UACC,SAAU4C,GACR,GAAIL,IAAuBhF,GAAaqF,EAAQD,YAAcJ,GAG5D,GAFAA,EAAqBK,EAAQD,WAEzBC,EAAQD,WACV,KAAOH,EAAEK,OAAS,GAChBhE,EAASc,OAAO6C,EAAEM,aAItBP,GAAqBK,EAAQD,WAEzBC,EAAQD,WACV9D,EAASc,OAAOiD,EAAQF,MAExBF,EAAEO,KAAKH,EAAQF,OAIrB,SAAUnD,GAER,KAAOiD,EAAEK,OAAS,GAChBhE,EAASc,OAAO6C,EAAEM,QAEpBjE,GAASW,QAAQD,IAEnB,WAEE,KAAOiD,EAAEK,OAAS,GAChBhE,EAASc,OAAO6C,EAAEM,QAEpBjE,GAASgB,eAGjB,OAAO6B,GAGT,QAASY,GAA2B7D,EAAQoD,GAC1CnE,KAAKe,OAASA,EACdf,KAAKwE,WAAa,GAAI1B,GAGpB9C,KAAKmE,OADHA,GAAUA,EAAO7B,UACLtC,KAAKwE,WAAWC,MAAMN,GAEtBnE,KAAKwE,WAGrBX,EAAUjD,KAAKZ,KAAMsC,EAAWvB,GAWlC,MAvEAsC,GAASuB,EAA4Bf,GA+DrCe,EAA2BjC,UAAU+B,MAAQ,WAC3C1E,KAAKwE,WAAWvC,QAAO,IAGzB2C,EAA2BjC,UAAUgC,OAAS,WAC5C3E,KAAKwE,WAAWvC,QAAO,IAGlB2C,GAEPnC,EAWFC,GAAgB4C,iBAAmB,SAAUtE,GAC3C,MAAO,IAAI4D,GAA2B5E,KAAMgB,GAG9C,IAAIuE,GAAwB,SAAU1B,GAIpC,QAASvB,GAAWnB,GAClB,MAAOnB,MAAKe,OAAOuB,UAAUnB,GAG/B,QAASoE,GAAsBxE,EAAQyE,GACrC3B,EAAUjD,KAAKZ,KAAMsC,EAAWvB,GAChCf,KAAKgB,QAAU,GAAIyE,GAAkBD,GACrCxF,KAAKe,OAASA,EAAO2E,UAAU1F,KAAKgB,SAAS2E,WAQ/C,MAjBAtC,GAASkC,EAAsB1B,GAY/B0B,EAAqB5C,UAAUiD,QAAU,SAAUC,GAEjD,MADqB,OAAjBA,IAAyBA,EAAgB,IACtC7F,KAAKgB,QAAQ4E,QAAQC,IAGvBN,GAEP9C,GAEEgD,EAAqB,SAAU5B,GAEjC,QAASvB,GAAWnB,GAClB,MAAOnB,MAAKgB,QAAQsB,UAAUnB,GAKhC,QAASsE,GAAkBD,GACV,MAAfA,IAAwBA,GAAc,GAEtC3B,EAAUjD,KAAKZ,KAAMsC,GACrBtC,KAAKgB,QAAU,GAAI8B,GACnB9C,KAAKwF,YAAcA,EACnBxF,KAAK8F,MAAQN,KAAmB,KAChCxF,KAAK+F,eAAiB,EACtB/F,KAAKgG,oBAAsBhD,EAC3BhD,KAAKiG,MAAQ,KACbjG,KAAKkG,WAAY,EACjBlG,KAAKmG,cAAe,EACpBnG,KAAKoG,qBAAuBpD,EAsE9B,MApFAK,GAASoC,EAAmB5B,GAiB5BP,EAAcmC,EAAkB9C,UAAWI,GACzCZ,YAAa,WACXnC,KAAKmG,cAAe,IAClBnG,KAAKwF,aAAqC,IAAtBxF,KAAK8F,MAAMX,SAAiBnF,KAAKgB,QAAQmB,eAEjEL,QAAS,SAAUmE,GACjBjG,KAAKkG,WAAY,EACjBlG,KAAKiG,MAAQA,IACXjG,KAAKwF,aAAqC,IAAtBxF,KAAK8F,MAAMX,SAAiBnF,KAAKgB,QAAQc,QAAQmE,IAEzEhE,OAAQ,SAAUoE,GAChB,GAAIC,IAAe,CAES,KAAxBtG,KAAK+F,eACP/F,KAAKwF,aAAexF,KAAK8F,MAAMT,KAAKgB,IAEX,KAAxBrG,KAAK+F,gBAAmD,IAA1B/F,KAAK+F,kBAA2B/F,KAAKuG,wBACpED,GAAe,GAEjBA,GAAgBtG,KAAKgB,QAAQiB,OAAOoE,IAEtCG,gBAAiB,SAAUX,GACzB,GAAI7F,KAAKwF,YAAa,CACpB,KAAOxF,KAAK8F,MAAMX,QAAUU,GAAiBA,EAAgB,GAC3D7F,KAAKgB,QAAQiB,OAAOjC,KAAK8F,MAAMV,SAC/BS,GAGF,OAA6B,KAAtB7F,KAAK8F,MAAMX,QACdU,cAAeA,EAAeY,aAAa,IAC3CZ,cAAeA,EAAeY,aAAa,GAajD,MAVIzG,MAAKkG,WACPlG,KAAKgB,QAAQc,QAAQ9B,KAAKiG,OAC1BjG,KAAKoG,qBAAqB7B,UAC1BvE,KAAKoG,qBAAuBpD,GACnBhD,KAAKmG,eACdnG,KAAKgB,QAAQmB,cACbnC,KAAKoG,qBAAqB7B,UAC1BvE,KAAKoG,qBAAuBpD,IAGrB6C,cAAeA,EAAeY,aAAa,IAEtDb,QAAS,SAAUjG,GACjBK,KAAKuG,uBACL,IAAIG,GAAO1G,KAAM2G,EAAI3G,KAAKwG,gBAAgB7G,GAEtCA,EAASgH,EAAEd,aACf,OAAKc,GAAEF,YAQEzD,GAPPhD,KAAK+F,eAAiBpG,EACtBK,KAAKgG,oBAAsB7C,EAAiB,WAC1CuD,EAAKX,eAAiB,IAGjB/F,KAAKgG,sBAKhBO,sBAAuB,WACrBvG,KAAKgG,oBAAoBzB,UACzBvE,KAAKgG,oBAAsBhD,KAIxByC,GACPhD,EAUFC,GAAgBkE,WAAa,SAAUpB,GAErC,MADmB,OAAfA,IAAwBA,GAAc,GACnC,GAAID,GAAqBvF,KAAMwF,GAGxC,IAAIqB,GAAyB,SAAUhD,GAErC,QAASvB,GAAWnB,GAClBnB,KAAKgE,aAAehE,KAAKe,OAAOuB,UAAU,GAAIwE,GAAoB3F,EAAUnB,KAAMA,KAAKgE,cAEvF,IAAI0C,GAAO1G,IAGX,OAFAuD,GAAiBwD,SAAS,WAAcL,EAAK3F,OAAO6E,QAAQ,KAErD5F,KAAKgE,aAKd,QAAS6C,GAAuB9F,GAC9B8C,EAAUjD,KAAKZ,KAAMsC,EAAWvB,GAChCf,KAAKe,OAASA,EAJhBsC,EAASwD,EAAuBhD,EAOhC,IAAIiD,GAAuB,SAAUE,GAInC,QAASF,GAAqB3F,EAAU8F,EAAYC,GAClDF,EAAQpG,KAAKZ,MACbA,KAAKmB,SAAWA,EAChBnB,KAAKiH,WAAaA,EAClBjH,KAAKkH,OAASA,EANhB7D,EAASyD,EAAqBE,EAS9B,IAAIG,GAA2BL,EAAoBnE,SA8BnD,OA5BAwE,GAAyBC,UAAY,WACnCpH,KAAKmB,SAASgB,cACdnC,KAAKuE,WAGP4C,EAAyBlB,MAAQ,SAAUA,GACzCjG,KAAKmB,SAASW,QAAQmE,GACtBjG,KAAKuE,WAGP4C,EAAyB/F,KAAO,SAAUiF,GACxCrG,KAAKmB,SAASc,OAAOoE,EAErB,IAAIK,GAAO1G,IACXuD,GAAiBwD,SAAS,WACxBL,EAAKO,WAAWlG,OAAO6E,QAAQ,MAInCuB,EAAyB5C,QAAU,WACjCvE,KAAKmB,SAAW,KACZnB,KAAKkH,SACPlH,KAAKkH,OAAO3C,UACZvE,KAAKkH,OAAS,MAEhBF,EAAQrE,UAAU4B,QAAQ3D,KAAKZ,OAG1B8G,GACPlE,EAEF,OAAOiE,IACPpE,EAOF8C,GAAqB5C,UAAU0E,YAAc,WAC3C,MAAO,IAAIR,GAAsB7G,MAGnC,IAAIsH,GAAsB,SAAUzD,GAElC,QAASvB,GAAWnB,GAClBnB,KAAKgE,aAAehE,KAAKe,OAAOuB,UAAU,GAAIiF,GAAiBpG,EAAUnB,KAAMA,KAAKgE,cAEpF,IAAI0C,GAAO1G,IAKX,OAJAuD,GAAiBwD,SAAS,WACxBL,EAAK3F,OAAO6E,QAAQc,EAAKc,cAGpBxH,KAAKgE,aAKd,QAASsD,GAAmBvG,EAAQyG,GAClC3D,EAAUjD,KAAKZ,KAAMsC,EAAWvB,GAChCf,KAAKe,OAASA,EACdf,KAAKwH,WAAaA,EALpBnE,EAASiE,EAAoBzD,EAQ7B,IAAI0D,GAAoB,SAAUP,GAIhC,QAASO,GAAiBpG,EAAU8F,EAAYC,GAC9ClH,KAAKmB,SAAWA,EAChBnB,KAAKiH,WAAaA,EAClBjH,KAAKkH,OAASA,EACdlH,KAAKyH,SAAW,EANlBpE,EAASkE,EAAkBP,EAS3B,IAAIU,GAA4BH,EAAiB5E,SAiCjD,OA/BA+E,GAA0BN,UAAY,WACpCpH,KAAKmB,SAASgB,cACdnC,KAAKuE,WAGPmD,EAA0BzB,MAAQ,SAAUA,GAC1CjG,KAAKmB,SAASW,QAAQmE,GACtBjG,KAAKuE,WAGPmD,EAA0BtG,KAAO,SAAUiF,GAIzC,GAHArG,KAAKmB,SAASc,OAAOoE,GAErBrG,KAAKyH,WAAazH,KAAKyH,SAAWzH,KAAKiH,WAAWO,WAC5B,IAAlBxH,KAAKyH,SAAgB,CACvB,GAAIf,GAAO1G,IACXuD,GAAiBwD,SAAS,WACxBL,EAAKO,WAAWlG,OAAO6E,QAAQc,EAAKO,WAAWO,gBAKrDE,EAA0BnD,QAAU,WAClCvE,KAAKmB,SAAW,KACZnB,KAAKkH,SACPlH,KAAKkH,OAAO3C,UACZvE,KAAKkH,OAAS,MAEhBF,EAAQrE,UAAU4B,QAAQ3D,KAAKZ,OAG1BuH,GACP3E,EAEF,OAAO0E,IACP7E,EAWA,OAJF8C,GAAqB5C,UAAUgF,SAAW,SAAUH,GAClD,MAAO,IAAIF,GAAmBtH,KAAMwH,IAG7B9G"}