| 1 | {"version":3,"file":"rx.backpressure.min.js","sources":["rx.backpressure.js"],"names":["factory","checkGlobal","value","Object","objectTypes","function","object","freeExports","exports","nodeType","freeModule","module","freeGlobal","global","freeSelf","self","freeWindow","window","thisGlobal","this","root","Function","define","amd","Rx","require","call","exp","undefined","tryCatcherGen","tryCatchTarget","apply","arguments","e","errorObj","combineLatestSource","source","subject","resultSelector","AnonymousObservable","o","next","x","i","values","hasValue","hasValueAll","every","identity","err","onError","res","tryCatch","onNext","isDone","onCompleted","Array","BinaryDisposable","subscribe","Observable","observableProto","prototype","AbstractObserver","internals","CompositeDisposable","NAryDisposable","Notification","Subject","Observer","disposableEmpty","Disposable","empty","disposableCreate","create","inherits","addProperties","defaultScheduler","Scheduler","currentThreadScheduler","currentThread","helpers","isScheduler","isFunction","checkDisposed","fn","TypeError","Pauser","__super__","pause","resume","PausableObservable","pauser","controller","merge","_subscribe","conn","publish","subscription","connection","pausable","distinctUntilChanged","b","connect","dispose","PausableBufferedObservable","drainQueue","q","length","shift","previousShouldFire","startWith","data","shouldFire","results","push","pausableBuffered","ControlledObservable","enableQueue","scheduler","ControlledSubject","multicast","refCount","request","numberOfItems","queue","requestedCount","requestedDisposable","error","hasFailed","hasCompleted","createOnCompleted","disposeCurrentRequest","createOnError","createOnNext","_processRequest","kind","first","accept","number","schedule","s","remaining","stopped","controlled","StopAndWaitObservable","scheduleMethod","StopAndWaitObserver","__sub__","observer","observable","cancel","scheduleDisposable","innerScheduleMethod","completed","stopAndWait","WindowedObservable","windowSize","WindowedObserver","received","windowed","pipe","dest","onDrain","addListener","write","String","emit","_isStdio","end","removeListener"],"mappings":";CAEE,SAAUA,GAMV,QAASC,GAAYC,GACnB,MAAQA,IAASA,EAAMC,SAAWA,OAAUD,EAAQ,KANtD,GAAIE,IACFC,YAAY,EACZC,QAAU,GAORC,EAAeH,QAAmBI,WAAYA,UAAYA,QAAQC,SAAYD,QAAU,KACxFE,EAAcN,QAAmBO,UAAWA,SAAWA,OAAOF,SAAYE,OAAS,KACnFC,EAAaX,EAAYM,GAAeG,GAAgC,gBAAXG,SAAuBA,QACpFC,EAAWb,EAAYG,QAAmBW,QAASA,MACnDC,EAAaf,EAAYG,QAAmBa,UAAWA,QAEvDC,GADiBR,GAAcA,EAAWF,UAAYD,EAAeA,EAAc,KACtEN,EAAYG,QAAmBe,QAASA,OACrDC,EAAOR,GAAgBI,KAAgBE,GAAcA,EAAWD,SAAYD,GAAeF,GAAYI,GAAcG,SAAS,gBAG5G,mBAAXC,SAAyBA,OAAOC,IACzCD,QAAQ,QAAS,SAAUE,EAAIhB,GAC7B,MAAOR,GAAQoB,EAAMZ,EAASgB,KAEL,gBAAXb,SAAuBA,QAAUA,OAAOH,UAAYD,EACpEI,OAAOH,QAAUR,EAAQoB,EAAMT,OAAOH,QAASiB,QAAQ,SAEvDL,EAAKI,GAAKxB,EAAQoB,KAAUA,EAAKI,MAEnCE,KAAKP,KAAM,SAAUC,EAAMO,EAAKH,EAAII,GA0BpC,QAASC,GAAcC,GACrB,MAAO,YACL,IACE,MAAOA,GAAeC,MAAMZ,KAAMa,WAClC,MAAOC,GAEP,MADAC,GAASD,EAAIA,EACNC,IA4Fb,QAASC,GAAoBC,EAAQC,EAASC,GAC5C,MAAO,IAAIC,GAAoB,SAAUC,GAOvC,QAASC,GAAKC,EAAGC,GAGf,GAFAC,EAAOD,GAAKD,EACZG,EAASF,IAAK,EACVG,IAAgBA,EAAcD,EAASE,MAAMC,IAAY,CAC3D,GAAIC,EAAO,MAAOT,GAAEU,QAAQD,EAC5B,IAAIE,GAAMC,EAASd,GAAgBP,MAAM,KAAMa,EAC/C,IAAIO,IAAQjB,EAAY,MAAOM,GAAEU,QAAQC,EAAIlB,EAC7CO,GAAEa,OAAOF,GAEXG,GAAUV,EAAO,IAAMJ,EAAEe,cAf3B,GAIEN,GAJEJ,IAAY,GAAO,GACrBC,GAAc,EACdQ,GAAS,EACTV,EAAS,GAAIY,OAAM,EAerB,OAAO,IAAIC,GACTrB,EAAOsB,UACL,SAAUhB,GACRD,EAAKC,EAAG,IAEV,SAAUT,GACJW,EAAO,GACTJ,EAAEU,QAAQjB,GAEVgB,EAAMhB,GAGV,WACEqB,GAAS,EACTV,EAAO,IAAMJ,EAAEe,gBAEnBlB,EAAQqB,UACN,SAAUhB,GACRD,EAAKC,EAAG,IAEV,SAAUT,GAAKO,EAAEU,QAAQjB,IACzB,WACEqB,GAAS,EACTb,GAAK,EAAM,OAGhBL,GAvKL,GAAIuB,GAAanC,EAAGmC,WAClBC,EAAkBD,EAAWE,UAC7BtB,EAAsBf,EAAGe,oBACzBuB,EAAmBtC,EAAGuC,UAAUD,iBAEhCL,GADsBjC,EAAGwC,oBACNxC,EAAGiC,kBACtBQ,EAAiBzC,EAAGyC,eACpBC,EAAe1C,EAAG0C,aAClBC,EAAU3C,EAAG2C,QACbC,EAAW5C,EAAG4C,SACdC,EAAkB7C,EAAG8C,WAAWC,MAChCC,EAAmBhD,EAAG8C,WAAWG,OACjCC,EAAWlD,EAAGuC,UAAUW,SACxBC,EAAgBnD,EAAGuC,UAAUY,cAC7BC,EAAmBpD,EAAGqD,UAAU,WAChCC,EAAyBtD,EAAGqD,UAAUE,cACtC/B,EAAWxB,EAAGwD,QAAQhC,SACtBiC,EAAczD,EAAGqD,UAAUI,YAC3BC,EAAa1D,EAAGwD,QAAQE,WAGtBhD,GAFcV,EAAG8C,WAAWa,eAEhBlD,OAaZmB,EAAW5B,EAAGuC,UAAUX,SAAW,SAAkBgC,GACvD,IAAKF,EAAWE,GAAO,KAAM,IAAIC,WAAU,wBAC3C,OAAOxD,GAAcuD,GAUvB5D,GAAG8D,OAAU,SAAUC,GAErB,QAASD,KACPC,EAAU7D,KAAKP,MAajB,MAfAuD,GAASY,EAAQC,GAQjBD,EAAOzB,UAAU2B,MAAQ,WAAcrE,KAAKkC,QAAO,IAKnDiC,EAAOzB,UAAU4B,OAAS,WAActE,KAAKkC,QAAO,IAE7CiC,GACPnB,EAEF,IAAIuB,GAAsB,SAAUH,GAElC,QAASG,GAAmBtD,EAAQuD,GAClCxE,KAAKiB,OAASA,EACdjB,KAAKyE,WAAa,GAAIzB,GAElBwB,GAAUA,EAAOjC,UACnBvC,KAAKwE,OAASxE,KAAKyE,WAAWC,MAAMF,GAEpCxE,KAAKwE,OAASxE,KAAKyE,WAGrBL,EAAU7D,KAAKP,MA4BjB,MAvCAuD,GAASgB,EAAoBH,GAc7BG,EAAmB7B,UAAUiC,WAAa,SAAUtD,GAClD,GAAIuD,GAAO5E,KAAKiB,OAAO4D,UACrBC,EAAeF,EAAKrC,UAAUlB,GAC9B0D,EAAa7B,EAEX8B,EAAWhF,KAAKwE,OAAOS,uBAAuB1C,UAAU,SAAU2C,GAChEA,EACFH,EAAaH,EAAKO,WAElBJ,EAAWK,UACXL,EAAa7B,IAIjB,OAAO,IAAIJ,IAAgBgC,EAAcC,EAAYC,KAGvDT,EAAmB7B,UAAU2B,MAAQ,WACnCrE,KAAKyE,WAAWvC,QAAO,IAGzBqC,EAAmB7B,UAAU4B,OAAS,WACpCtE,KAAKyE,WAAWvC,QAAO,IAGlBqC,GAEP/B,EAUFC,GAAgBuC,SAAW,SAAUR,GACnC,MAAO,IAAID,GAAmBvE,KAAMwE,GAoDtC,IAAIa,GAA8B,SAAUjB,GAE1C,QAASiB,GAA2BpE,EAAQuD,GAC1CxE,KAAKiB,OAASA,EACdjB,KAAKyE,WAAa,GAAIzB,GAElBwB,GAAUA,EAAOjC,UACnBvC,KAAKwE,OAASxE,KAAKyE,WAAWC,MAAMF,GAEpCxE,KAAKwE,OAASxE,KAAKyE,WAGrBL,EAAU7D,KAAKP,MAmDjB,MA9DAuD,GAAS8B,EAA4BjB,GAcrCiB,EAA2B3C,UAAUiC,WAAa,SAAUtD,GAG1D,QAASiE,KAAe,KAAOC,EAAEC,OAAS,GAAKnE,EAAEa,OAAOqD,EAAEE,SAF1D,GAAYC,GAARH,KAIAT,EACF9D,EACEhB,KAAKiB,OACLjB,KAAKwE,OAAOmB,WAAU,GAAOV,uBAC7B,SAAUW,EAAMC,GACd,OAASD,KAAMA,EAAMC,WAAYA,KAElCtD,UACC,SAAUuD,GACJJ,IAAuBjF,GAAaqF,EAAQD,aAAeH,GAC7DA,EAAqBI,EAAQD,WAEzBC,EAAQD,YAAcP,MAE1BI,EAAqBI,EAAQD,WAEzBC,EAAQD,WACVxE,EAAEa,OAAO4D,EAAQF,MAEjBL,EAAEQ,KAAKD,EAAQF,QAIrB,SAAU9D,GACRwD,IACAjE,EAAEU,QAAQD,IAEZ,WACEwD,IACAjE,EAAEe,eAGV,OAAO0C,IAGTO,EAA2B3C,UAAU2B,MAAQ,WAC3CrE,KAAKyE,WAAWvC,QAAO,IAGzBmD,EAA2B3C,UAAU4B,OAAS,WAC5CtE,KAAKyE,WAAWvC,QAAO,IAGlBmD,GAEP7C,EAWFC,GAAgBuD,iBAAmB,SAAUxB,GAC3C,MAAO,IAAIa,GAA2BrF,KAAMwE,GAG9C,IAAIyB,GAAwB,SAAU7B,GAEpC,QAAS6B,GAAsBhF,EAAQiF,EAAaC,GAClD/B,EAAU7D,KAAKP,MACfA,KAAKkB,QAAU,GAAIkF,GAAkBF,EAAaC,GAClDnG,KAAKiB,OAASA,EAAOoF,UAAUrG,KAAKkB,SAASoF,WAW/C,MAfA/C,GAAS0C,EAAsB7B,GAO/B6B,EAAqBvD,UAAUiC,WAAa,SAAUtD,GACpD,MAAOrB,MAAKiB,OAAOsB,UAAUlB,IAG/B4E,EAAqBvD,UAAU6D,QAAU,SAAUC,GACjD,MAAOxG,MAAKkB,QAAQqF,QAAyB,MAAjBC,EAAwB,GAAKA,IAGpDP,GAEPzD,GAEE4D,EAAqB,SAAUhC,GAEjC,QAASgC,GAAkBF,EAAaC,GACvB,MAAfD,IAAwBA,GAAc,GAEtC9B,EAAU7D,KAAKP,MACfA,KAAKkB,QAAU,GAAI8B,GACnBhD,KAAKkG,YAAcA,EACnBlG,KAAKyG,MAAQP,KAAmB,KAChClG,KAAK0G,eAAiB,EACtB1G,KAAK2G,oBAAsB,KAC3B3G,KAAK4G,MAAQ,KACb5G,KAAK6G,WAAY,EACjB7G,KAAK8G,cAAe,EACpB9G,KAAKmG,UAAYA,GAAaxC,EAgFhC,MA7FAJ,GAAS6C,EAAmBhC,GAgB5BZ,EAAc4C,EAAkB1D,UAAWO,GACzC0B,WAAY,SAAUtD,GACpB,MAAOrB,MAAKkB,QAAQqB,UAAUlB,IAEhCe,YAAa,WACXpC,KAAK8G,cAAe,EACf9G,KAAKkG,aAAqC,IAAtBlG,KAAKyG,MAAMjB,OAIlCxF,KAAKyG,MAAMV,KAAKhD,EAAagE,sBAH7B/G,KAAKkB,QAAQkB,cACbpC,KAAKgH,0BAKTjF,QAAS,SAAU6E,GACjB5G,KAAK6G,WAAY,EACjB7G,KAAK4G,MAAQA,EACR5G,KAAKkG,aAAqC,IAAtBlG,KAAKyG,MAAMjB,OAIlCxF,KAAKyG,MAAMV,KAAKhD,EAAakE,cAAcL,KAH3C5G,KAAKkB,QAAQa,QAAQ6E,GACrB5G,KAAKgH,0BAKT9E,OAAQ,SAAUnD,GACZiB,KAAK0G,gBAAkB,EACzB1G,KAAKkG,aAAelG,KAAKyG,MAAMV,KAAKhD,EAAamE,aAAanI,KAEnC,IAA1BiB,KAAK0G,kBAA2B1G,KAAKgH,wBACtChH,KAAKkB,QAAQgB,OAAOnD,KAGxBoI,gBAAiB,SAAUX,GACzB,GAAIxG,KAAKkG,YACP,KAAOlG,KAAKyG,MAAMjB,OAAS,IAAMgB,EAAgB,GAA4B,MAAvBxG,KAAKyG,MAAM,GAAGW,OAAe,CACjF,GAAIC,GAAQrH,KAAKyG,MAAMhB,OACvB4B,GAAMC,OAAOtH,KAAKkB,SACC,MAAfmG,EAAMD,KACRZ,KAEAxG,KAAKgH,wBACLhH,KAAKyG,UAKX,MAAOD,IAETD,QAAS,SAAUgB,GACjBvH,KAAKgH,uBACL,IAAIpH,GAAOI,IAkBX,OAhBAA,MAAK2G,oBAAsB3G,KAAKmG,UAAUqB,SAASD,EACnD,SAASE,EAAGjG,GACV,GAAIkG,GAAY9H,EAAKuH,gBAAgB3F,GACjCmG,EAAU/H,EAAKkH,cAAgBlH,EAAKiH,SACxC,QAAKc,GAAWD,EAAY,GAC1B9H,EAAK8G,eAAiBgB,EAEfrE,EAAiB,WACtBzD,EAAK8G,eAAiB,KAJ1B,SAYK1G,KAAK2G,qBAEdK,sBAAuB,WACjBhH,KAAK2G,sBACP3G,KAAK2G,oBAAoBvB,UACzBpF,KAAK2G,oBAAsB,SAK1BP,GACP5D,EAWFC,GAAgBmF,WAAa,SAAU1B,EAAaC,GAQlD,MANID,IAAepC,EAAYoC,KAC7BC,EAAYD,EACZA,GAAc,GAGG,MAAfA,IAAwBA,GAAc,GACnC,GAAID,GAAqBjG,KAAMkG,EAAaC,GAGrD,IAAI0B,GAAyB,SAAUzD,GAErC,QAASyD,GAAuB5G,GAC9BmD,EAAU7D,KAAKP,MACfA,KAAKiB,OAASA,EAGhB,QAAS6G,GAAeL,EAAG7H,GACzBA,EAAKqB,OAAOsF,QAAQ,GAPtBhD,EAASsE,EAAuBzD,GAUhCyD,EAAsBnF,UAAUiC,WAAa,SAAUtD,GAErD,MADArB,MAAK8E,aAAe9E,KAAKiB,OAAOsB,UAAU,GAAIwF,GAAoB1G,EAAGrB,KAAMA,KAAK8E,eACzE,GAAIxC,GACTtC,KAAK8E,aACLrB,EAAiB+D,SAASxH,KAAM8H,IAIpC,IAAIC,GAAuB,SAAUC,GAEnC,QAASD,GAAqBE,EAAUC,EAAYC,GAClDH,EAAQzH,KAAKP,MACbA,KAAKiI,SAAWA,EAChBjI,KAAKkI,WAAaA,EAClBlI,KAAKmI,OAASA,EACdnI,KAAKoI,mBAAqB,KAa5B,QAASC,GAAoBZ,EAAG7H,GAC9BA,EAAKsI,WAAWjH,OAAOsF,QAAQ,GAqBjC,MAzCAhD,GAASwE,EAAqBC,GAS9BD,EAAoBrF,UAAU4F,UAAY,WACxCtI,KAAKiI,SAAS7F,cACdpC,KAAKoF,WAGP2C,EAAoBrF,UAAUkE,MAAQ,SAAUA,GAC9C5G,KAAKiI,SAASlG,QAAQ6E,GACtB5G,KAAKoF,WAOP2C,EAAoBrF,UAAUpB,KAAO,SAAUvC,GAC7CiB,KAAKiI,SAAS/F,OAAOnD,GACrBiB,KAAKoI,mBAAqB3E,EAAiB+D,SAASxH,KAAMqI,IAG5DR,EAAsBzC,QAAU,WAC9BpF,KAAKiI,SAAW,KACZjI,KAAKmI,SACPnI,KAAKmI,OAAO/C,UACZpF,KAAKmI,OAAS,MAEZnI,KAAKoI,qBACPpI,KAAKoI,mBAAmBhD,UACxBpF,KAAKoI,mBAAqB,MAE5BJ,EAAQtF,UAAU0C,QAAQ7E,KAAKP,OAG1B+H,GACPpF,EAEF,OAAOkF,IACPrF,EAOFyD,GAAqBvD,UAAU6F,YAAc,WAC3C,MAAO,IAAIV,GAAsB7H,MAGnC,IAAIwI,GAAsB,SAAUpE,GAElC,QAASoE,GAAmBvH,EAAQwH,GAClCrE,EAAU7D,KAAKP,MACfA,KAAKiB,OAASA,EACdjB,KAAKyI,WAAaA,EAGpB,QAASX,GAAeL,EAAG7H,GACzBA,EAAKqB,OAAOsF,QAAQ3G,EAAK6I,YAR3BlF,EAASiF,EAAoBpE,GAW7BoE,EAAmB9F,UAAUiC,WAAa,SAAUtD,GAElD,MADArB,MAAK8E,aAAe9E,KAAKiB,OAAOsB,UAAU,GAAImG,GAAiBrH,EAAGrB,KAAMA,KAAK8E,eACtE,GAAIxC,GACTtC,KAAK8E,aACLrB,EAAiB+D,SAASxH,KAAM8H,IAIpC,IAAIY,GAAoB,SAAUV,GAEhC,QAASU,GAAiBT,EAAUC,EAAYC,GAC9CnI,KAAKiI,SAAWA,EAChBjI,KAAKkI,WAAaA,EAClBlI,KAAKmI,OAASA,EACdnI,KAAK2I,SAAW,EAChB3I,KAAKoI,mBAAqB,KAC1BJ,EAAQzH,KAAKP,MAaf,QAASqI,GAAoBZ,EAAG7H,GAC9BA,EAAKsI,WAAWjH,OAAOsF,QAAQ3G,EAAKsI,WAAWO,YAsBjD,MA3CAlF,GAASmF,EAAkBV,GAU3BU,EAAiBhG,UAAU4F,UAAY,WACrCtI,KAAKiI,SAAS7F,cACdpC,KAAKoF,WAGPsD,EAAiBhG,UAAUkE,MAAQ,SAAUA,GAC3C5G,KAAKiI,SAASlG,QAAQ6E,GACtB5G,KAAKoF,WAOPsD,EAAiBhG,UAAUpB,KAAO,SAAUvC,GAC1CiB,KAAKiI,SAAS/F,OAAOnD,GACrBiB,KAAK2I,WAAa3I,KAAK2I,SAAW3I,KAAKkI,WAAWO,WAChC,IAAlBzI,KAAK2I,WAAmB3I,KAAKoI,mBAAqB3E,EAAiB+D,SAASxH,KAAMqI,KAGpFK,EAAiBhG,UAAU0C,QAAU,WACnCpF,KAAKiI,SAAW,KACZjI,KAAKmI,SACPnI,KAAKmI,OAAO/C,UACZpF,KAAKmI,OAAS,MAEZnI,KAAKoI,qBACPpI,KAAKoI,mBAAmBhD,UACxBpF,KAAKoI,mBAAqB,MAE5BJ,EAAQtF,UAAU0C,QAAQ7E,KAAKP,OAG1B0I,GACP/F,EAEF,OAAO6F,IACPhG,EA2CF,OApCAyD,GAAqBvD,UAAUkG,SAAW,SAAUH,GAClD,MAAO,IAAID,GAAmBxI,KAAMyI,IAQtChG,EAAgBoG,KAAO,SAAUC,GAG/B,QAASC,KACP9H,EAAOqD,SAHT,GAAIrD,GAASjB,KAAKgG,kBAuBlB,OAjBA8C,GAAKE,YAAY,QAASD,GAE1B9H,EAAOsB,UACL,SAAUhB,IACPuH,EAAKG,MAAMC,OAAO3H,KAAON,EAAOoD,SAEnC,SAAUvC,GACRgH,EAAKK,KAAK,QAASrH,IAErB,YAEGgH,EAAKM,UAAYN,EAAKO,MACvBP,EAAKQ,eAAe,QAASP,KAGjC9H,EAAOqD,SAEAwE,GAGFzI"} |