| 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","paused","merge","_subscribe","conn","publish","subscription","connection","pausable","startWith","distinctUntilChanged","b","connect","dispose","PausableBufferedObservable","drainQueue","q","length","shift","previousShouldFire","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","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,IA+Fb,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,GA1KL,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,GACtBhD,KAAK0E,QAAS,EAEVF,GAAUA,EAAOjC,UACnBvC,KAAKwE,OAASxE,KAAKyE,WAAWE,MAAMH,GAEpCxE,KAAKwE,OAASxE,KAAKyE,WAGrBL,EAAU7D,KAAKP,MA8BjB,MA1CAuD,GAASgB,EAAoBH,GAe7BG,EAAmB7B,UAAUkC,WAAa,SAAUvD,GAClD,GAAIwD,GAAO7E,KAAKiB,OAAO6D,UACrBC,EAAeF,EAAKtC,UAAUlB,GAC9B2D,EAAa9B,EAEX+B,EAAWjF,KAAKwE,OAAOU,WAAWlF,KAAK0E,QAAQS,uBAAuB5C,UAAU,SAAU6C,GACxFA,EACFJ,EAAaH,EAAKQ,WAElBL,EAAWM,UACXN,EAAa9B,IAIjB,OAAO,IAAIJ,IAAgBiC,EAAcC,EAAYC,KAGvDV,EAAmB7B,UAAU2B,MAAQ,WACnCrE,KAAK0E,QAAS,EACd1E,KAAKyE,WAAWvC,QAAO,IAGzBqC,EAAmB7B,UAAU4B,OAAS,WACpCtE,KAAK0E,QAAS,EACd1E,KAAKyE,WAAWvC,QAAO,IAGlBqC,GAEP/B,EAUFC,GAAgBwC,SAAW,SAAUT,GACnC,MAAO,IAAID,GAAmBvE,KAAMwE,GAoDtC,IAAIe,GAA8B,SAAUnB,GAE1C,QAASmB,GAA2BtE,EAAQuD,GAC1CxE,KAAKiB,OAASA,EACdjB,KAAKyE,WAAa,GAAIzB,GACtBhD,KAAK0E,QAAS,EAEVF,GAAUA,EAAOjC,UACnBvC,KAAKwE,OAASxE,KAAKyE,WAAWE,MAAMH,GAEpCxE,KAAKwE,OAASxE,KAAKyE,WAGrBL,EAAU7D,KAAKP,MAqDjB,MAjEAuD,GAASgC,EAA4BnB,GAerCmB,EAA2B7C,UAAUkC,WAAa,SAAUvD,GAG1D,QAASmE,KAAe,KAAOC,EAAEC,OAAS,GAAKrE,EAAEa,OAAOuD,EAAEE,SAF1D,GAAYC,GAARH,KAIAV,EACF/D,EACEhB,KAAKiB,OACLjB,KAAKwE,OAAOU,WAAWlF,KAAK0E,QAAQS,uBACpC,SAAUU,EAAMC,GACd,OAASD,KAAMA,EAAMC,WAAYA,KAElCvD,UACC,SAAUwD,GACJH,IAAuBnF,GAAasF,EAAQD,aAAeF,GAC7DA,EAAqBG,EAAQD,WAEzBC,EAAQD,YAAcN,MAE1BI,EAAqBG,EAAQD,WAEzBC,EAAQD,WACVzE,EAAEa,OAAO6D,EAAQF,MAEjBJ,EAAEO,KAAKD,EAAQF,QAIrB,SAAU/D,GACR0D,IACAnE,EAAEU,QAAQD,IAEZ,WACE0D,IACAnE,EAAEe,eAGV,OAAO2C,IAGTQ,EAA2B7C,UAAU2B,MAAQ,WAC3CrE,KAAK0E,QAAS,EACd1E,KAAKyE,WAAWvC,QAAO,IAGzBqD,EAA2B7C,UAAU4B,OAAS,WAC5CtE,KAAK0E,QAAS,EACd1E,KAAKyE,WAAWvC,QAAO,IAGlBqD,GAEP/C,EAWFC,GAAgBwD,iBAAmB,SAAUzB,GAC3C,MAAO,IAAIe,GAA2BvF,KAAMwE,GAG9C,IAAI0B,GAAwB,SAAU9B,GAEpC,QAAS8B,GAAsBjF,EAAQkF,EAAaC,GAClDhC,EAAU7D,KAAKP,MACfA,KAAKkB,QAAU,GAAImF,GAAkBF,EAAaC,GAClDpG,KAAKiB,OAASA,EAAOqF,UAAUtG,KAAKkB,SAASqF,WAW/C,MAfAhD,GAAS2C,EAAsB9B,GAO/B8B,EAAqBxD,UAAUkC,WAAa,SAAUvD,GACpD,MAAOrB,MAAKiB,OAAOsB,UAAUlB,IAG/B6E,EAAqBxD,UAAU8D,QAAU,SAAUC,GACjD,MAAOzG,MAAKkB,QAAQsF,QAAyB,MAAjBC,EAAwB,GAAKA,IAGpDP,GAEP1D,GAEE6D,EAAqB,SAAUjC,GAEjC,QAASiC,GAAkBF,EAAaC,GACvB,MAAfD,IAAwBA,GAAc,GAEtC/B,EAAU7D,KAAKP,MACfA,KAAKkB,QAAU,GAAI8B,GACnBhD,KAAKmG,YAAcA,EACnBnG,KAAK0G,MAAQP,KAAmB,KAChCnG,KAAK2G,eAAiB,EACtB3G,KAAK4G,oBAAsB,KAC3B5G,KAAK6G,MAAQ,KACb7G,KAAK8G,WAAY,EACjB9G,KAAK+G,cAAe,EACpB/G,KAAKoG,UAAYA,GAAazC,EAgFhC,MA7FAJ,GAAS8C,EAAmBjC,GAgB5BZ,EAAc6C,EAAkB3D,UAAWO,GACzC2B,WAAY,SAAUvD,GACpB,MAAOrB,MAAKkB,QAAQqB,UAAUlB,IAEhCe,YAAa,WACXpC,KAAK+G,cAAe,EACf/G,KAAKmG,aAAqC,IAAtBnG,KAAK0G,MAAMhB,OAIlC1F,KAAK0G,MAAMV,KAAKjD,EAAaiE,sBAH7BhH,KAAKkB,QAAQkB,cACbpC,KAAKiH,0BAKTlF,QAAS,SAAU8E,GACjB7G,KAAK8G,WAAY,EACjB9G,KAAK6G,MAAQA,EACR7G,KAAKmG,aAAqC,IAAtBnG,KAAK0G,MAAMhB,OAIlC1F,KAAK0G,MAAMV,KAAKjD,EAAamE,cAAcL,KAH3C7G,KAAKkB,QAAQa,QAAQ8E,GACrB7G,KAAKiH,0BAKT/E,OAAQ,SAAUnD,GACZiB,KAAK2G,gBAAkB,EACzB3G,KAAKmG,aAAenG,KAAK0G,MAAMV,KAAKjD,EAAaoE,aAAapI,KAEnC,IAA1BiB,KAAK2G,kBAA2B3G,KAAKiH,wBACtCjH,KAAKkB,QAAQgB,OAAOnD,KAGxBqI,gBAAiB,SAAUX,GACzB,GAAIzG,KAAKmG,YACP,KAAOnG,KAAK0G,MAAMhB,OAAS,IAAMe,EAAgB,GAA4B,MAAvBzG,KAAK0G,MAAM,GAAGW,OAAe,CACjF,GAAIC,GAAQtH,KAAK0G,MAAMf,OACvB2B,GAAMC,OAAOvH,KAAKkB,SACC,MAAfoG,EAAMD,KACRZ,KAEAzG,KAAKiH,wBACLjH,KAAK0G,UAKX,MAAOD,IAETD,QAAS,SAAUgB,GACjBxH,KAAKiH,uBACL,IAAIrH,GAAOI,IAkBX,OAhBAA,MAAK4G,oBAAsB5G,KAAKoG,UAAUqB,SAASD,EACnD,SAASE,EAAGlG,GACV,GAAImG,GAAY/H,EAAKwH,gBAAgB5F,GACjCoG,EAAUhI,EAAKmH,cAAgBnH,EAAKkH,SACxC,QAAKc,GAAWD,EAAY,GAC1B/H,EAAK+G,eAAiBgB,EAEftE,EAAiB,WACtBzD,EAAK+G,eAAiB,KAJ1B,SAYK3G,KAAK4G,qBAEdK,sBAAuB,WACjBjH,KAAK4G,sBACP5G,KAAK4G,oBAAoBtB,UACzBtF,KAAK4G,oBAAsB,SAK1BP,GACP7D,EAWFC,GAAgBoF,WAAa,SAAU1B,EAAaC,GAQlD,MANID,IAAerC,EAAYqC,KAC7BC,EAAYD,EACZA,GAAc,GAGG,MAAfA,IAAwBA,GAAc,GACnC,GAAID,GAAqBlG,KAAMmG,EAAaC,GAGrD,IAAI0B,GAAyB,SAAU1D,GAErC,QAAS0D,GAAuB7G,GAC9BmD,EAAU7D,KAAKP,MACfA,KAAKiB,OAASA,EAGhB,QAAS8G,GAAeL,EAAG9H,GACzB,MAAOA,GAAKqB,OAAOuF,QAAQ,GAP7BjD,EAASuE,EAAuB1D,GAUhC0D,EAAsBpF,UAAUkC,WAAa,SAAUvD,GAErD,MADArB,MAAK+E,aAAe/E,KAAKiB,OAAOsB,UAAU,GAAIyF,GAAoB3G,EAAGrB,KAAMA,KAAK+E,eACzE,GAAIzC,GACTtC,KAAK+E,aACLtB,EAAiBgE,SAASzH,KAAM+H,IAIpC,IAAIC,GAAuB,SAAUC,GAEnC,QAASD,GAAqBE,EAAUC,EAAYC,GAClDH,EAAQ1H,KAAKP,MACbA,KAAKkI,SAAWA,EAChBlI,KAAKmI,WAAaA,EAClBnI,KAAKoI,OAASA,EACdpI,KAAKqI,mBAAqB,KAa5B,QAASC,GAAoBZ,EAAG9H,GAC9B,MAAOA,GAAKuI,WAAWlH,OAAOuF,QAAQ,GAqBxC,MAzCAjD,GAASyE,EAAqBC,GAS9BD,EAAoBtF,UAAU6F,UAAY,WACxCvI,KAAKkI,SAAS9F,cACdpC,KAAKsF,WAGP0C,EAAoBtF,UAAUmE,MAAQ,SAAUA,GAC9C7G,KAAKkI,SAASnG,QAAQ8E,GACtB7G,KAAKsF,WAOP0C,EAAoBtF,UAAUpB,KAAO,SAAUvC,GAC7CiB,KAAKkI,SAAShG,OAAOnD,GACrBiB,KAAKqI,mBAAqB5E,EAAiBgE,SAASzH,KAAMsI,IAG5DN,EAAoB1C,QAAU,WAC5BtF,KAAKkI,SAAW,KACZlI,KAAKoI,SACPpI,KAAKoI,OAAO9C,UACZtF,KAAKoI,OAAS,MAEZpI,KAAKqI,qBACPrI,KAAKqI,mBAAmB/C,UACxBtF,KAAKqI,mBAAqB,MAE5BJ,EAAQvF,UAAU4C,QAAQ/E,KAAKP,OAG1BgI,GACPrF,EAEF,OAAOmF,IACPtF,EAOF0D,GAAqBxD,UAAU8F,YAAc,WAC3C,MAAO,IAAIV,GAAsB9H,MAGnC,IAAIyI,GAAsB,SAAUrE,GAElC,QAASqE,GAAmBxH,EAAQyH,GAClCtE,EAAU7D,KAAKP,MACfA,KAAKiB,OAASA,EACdjB,KAAK0I,WAAaA,EAGpB,QAASX,GAAeL,EAAG9H,GACzB,MAAOA,GAAKqB,OAAOuF,QAAQ5G,EAAK8I,YARlCnF,EAASkF,EAAoBrE,GAW7BqE,EAAmB/F,UAAUkC,WAAa,SAAUvD,GAElD,MADArB,MAAK+E,aAAe/E,KAAKiB,OAAOsB,UAAU,GAAIoG,GAAiBtH,EAAGrB,KAAMA,KAAK+E,eACtE,GAAIzC,GACTtC,KAAK+E,aACLtB,EAAiBgE,SAASzH,KAAM+H,IAIpC,IAAIY,GAAoB,SAAUV,GAEhC,QAASU,GAAiBT,EAAUC,EAAYC,GAC9CpI,KAAKkI,SAAWA,EAChBlI,KAAKmI,WAAaA,EAClBnI,KAAKoI,OAASA,EACdpI,KAAK4I,SAAW,EAChB5I,KAAKqI,mBAAqB,KAC1BJ,EAAQ1H,KAAKP,MAaf,QAASsI,GAAoBZ,EAAG9H,GAC9B,MAAOA,GAAKuI,WAAWlH,OAAOuF,QAAQ5G,EAAKuI,WAAWO,YAsBxD,MA3CAnF,GAASoF,EAAkBV,GAU3BU,EAAiBjG,UAAU6F,UAAY,WACrCvI,KAAKkI,SAAS9F,cACdpC,KAAKsF,WAGPqD,EAAiBjG,UAAUmE,MAAQ,SAAUA,GAC3C7G,KAAKkI,SAASnG,QAAQ8E,GACtB7G,KAAKsF,WAOPqD,EAAiBjG,UAAUpB,KAAO,SAAUvC,GAC1CiB,KAAKkI,SAAShG,OAAOnD,GACrBiB,KAAK4I,WAAa5I,KAAK4I,SAAW5I,KAAKmI,WAAWO,WAChC,IAAlB1I,KAAK4I,WAAmB5I,KAAKqI,mBAAqB5E,EAAiBgE,SAASzH,KAAMsI,KAGpFK,EAAiBjG,UAAU4C,QAAU,WACnCtF,KAAKkI,SAAW,KACZlI,KAAKoI,SACPpI,KAAKoI,OAAO9C,UACZtF,KAAKoI,OAAS,MAEZpI,KAAKqI,qBACPrI,KAAKqI,mBAAmB/C,UACxBtF,KAAKqI,mBAAqB,MAE5BJ,EAAQvF,UAAU4C,QAAQ/E,KAAKP,OAG1B2I,GACPhG,EAEF,OAAO8F,IACPjG,EA2CF,OApCA0D,GAAqBxD,UAAUmG,SAAW,SAAUH,GAClD,MAAO,IAAID,GAAmBzI,KAAM0I,IAQtCjG,EAAgBqG,KAAO,SAAUC,GAG/B,QAASC,KACP/H,EAAOqD,SAHT,GAAIrD,GAASjB,KAAKiG,kBAuBlB,OAjBA8C,GAAKE,YAAY,QAASD,GAE1B/H,EAAOsB,UACL,SAAUhB,IACPwH,EAAKG,MAAM3H,IAAMN,EAAOoD,SAE3B,SAAUvC,GACRiH,EAAKI,KAAK,QAASrH,IAErB,YAEGiH,EAAKK,UAAYL,EAAKM,MACvBN,EAAKO,eAAe,QAASN,KAGjC/H,EAAOqD,SAEAyE,GAGF1I"}
|
