{"version":3,"file":"rx.lite.extras.min.js","sources":["rx.lite.extras.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","argsOrArray","args","idx","length","Array","isArray","slice","ScheduledDisposable","scheduler","disposable","isDisposed","arrayIndexOfComparer","array","item","comparer","i","len","HashSet","set","Observable","observableProto","prototype","observableNever","never","observableThrow","throwException","AnonymousObservable","Observer","Subject","internals","helpers","ScheduledObserver","SerialDisposable","SingleAssignmentDisposable","CompositeDisposable","RefCountDisposable","disposableEmpty","Disposable","empty","immediateScheduler","Scheduler","immediate","addRef","defaultKeySerializer","isPromise","identity","inherits","isScheduler","noop","observableFromPromise","fromPromise","argumentOutOfRange","dispose","parent","schedule","ObserveOnObserver","_super","CheckedObserver","observer","_observer","_state","CheckedObserverPrototype","onNext","value","checkAccess","e","onError","err","onCompleted","Error","__super__","cancel","_cancel","next","ensureActive","error","completed","observeOn","source","subscribe","subscribeOn","m","d","setDisposable","generate","initialState","condition","iterate","resultSelector","currentThreadScheduler","first","state","scheduleRecursive","self","hasResult","result","exception","using","resourceFactory","observableFactory","resource","amb","rightSource","leftSource","choiceL","choice","leftChoice","rightSubscription","choiceR","rightChoice","leftSubscription","left","right","func","previous","current","acc","items","arguments","onErrorResumeNext","second","sources","pos","subscription","cancelable","bind","bufferWithCount","count","skip","windowWithCount","selectMany","x","toArray","where","Infinity","Math","abs","createWindow","s","q","push","refCountDisposable","n","c","shift","takeLastBuffer","defaultIfEmpty","defaultValue","found","retValue","distinct","keySelector","defaultComparer","hashSet","key"],"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,GA6BpC,QAASiB,GAAYC,EAAMC,GACzB,MAAuB,KAAhBD,EAAKE,QAAgBC,MAAMC,QAAQJ,EAAKC,IAC7CD,EAAKC,GACLI,EAAMR,KAAKG,GAKb,QAASM,GAAoBC,EAAWC,GACpCvB,KAAKsB,UAAYA,EACjBtB,KAAKuB,WAAaA,EAClBvB,KAAKwB,YAAa,EA8bxB,QAASC,GAAqBC,EAAOC,EAAMC,GACzC,IAAK,GAAIC,GAAI,EAAGC,EAAMJ,EAAMT,OAAYa,EAAJD,EAASA,IAC3C,GAAID,EAASF,EAAMG,GAAIF,GAAS,MAAOE,EAEzC,OAAO,GAGT,QAASE,GAAQH,GACf5B,KAAK4B,SAAWA,EAChB5B,KAAKgC,OA5eP,GAAIC,GAAavB,EAAGuB,WAClBC,EAAkBD,EAAWE,UAC7BC,EAAkBH,EAAWI,MAC7BC,EAAkBL,EAAWM,eAC7BC,EAAsB9B,EAAG8B,oBACzBC,EAAW/B,EAAG+B,SACdC,EAAUhC,EAAGgC,QACbC,EAAYjC,EAAGiC,UACfC,EAAUlC,EAAGkC,QACbC,EAAoBF,EAAUE,kBAC9BC,EAAmBpC,EAAGoC,iBACtBC,EAA6BrC,EAAGqC,2BAChCC,EAAsBtC,EAAGsC,oBACzBC,EAAqBvC,EAAGuC,mBACxBC,EAAkBxC,EAAGyC,WAAWC,MAChCC,EAAqB3C,EAAG4C,UAAUC,UAElCC,GADuBZ,EAAQa,qBACtB/C,EAAGiC,UAAUa,QAEtBE,GADWd,EAAQe,SACPf,EAAQc,WACpBE,EAAWjB,EAAUiB,SAErBC,GADOjB,EAAQkB,KACDlB,EAAQiB,aACtBE,EAAwB9B,EAAW+B,YACnC5C,EAAQF,MAAMiB,UAAUf,MAQtB6C,EAAqB,uBAQvB5C,GAAoBc,UAAU+B,QAAU,WACpC,GAAIC,GAASnE,IACbA,MAAKsB,UAAU8C,SAAS,WACfD,EAAO3C,aACR2C,EAAO3C,YAAa,EACpB2C,EAAO5C,WAAW2C,aAK9B,IAqDEG,IArDqB,SAAUC,GAG7B,QAASC,GAAgBC,GACrBF,EAAO1D,KAAKZ,MACZA,KAAKyE,UAAYD,EACjBxE,KAAK0E,OAAS,EALlBd,EAASW,EAAiBD,EAQ1B,IAAIK,GAA2BJ,EAAgBpC,SAyC/C,OAvCAwC,GAAyBC,OAAS,SAAUC,GACxC7E,KAAK8E,aACL,KACI9E,KAAKyE,UAAUG,OAAOC,GACxB,MAAOE,GACL,KAAMA,GACR,QACE/E,KAAK0E,OAAS,IAItBC,EAAyBK,QAAU,SAAUC,GACzCjF,KAAK8E,aACL,KACI9E,KAAKyE,UAAUO,QAAQC,GACzB,MAAOF,GACL,KAAMA,GACR,QACE/E,KAAK0E,OAAS,IAItBC,EAAyBO,YAAc,WACnClF,KAAK8E,aACL,KACI9E,KAAKyE,UAAUS,cACjB,MAAOH,GACL,KAAMA,GACR,QACE/E,KAAK0E,OAAS,IAItBC,EAAyBG,YAAc,WACnC,GAAoB,IAAhB9E,KAAK0E,OAAgB,KAAM,IAAIS,OAAM,uBACzC,IAAoB,IAAhBnF,KAAK0E,OAAgB,KAAM,IAAIS,OAAM,qBACrB,KAAhBnF,KAAK0E,SAAgB1E,KAAK0E,OAAS,IAGpCH,GACT9B,GAEoB,SAAW2C,GAGjC,QAASf,GAAkB/C,EAAWkD,EAAUa,GAC9CD,EAAUxE,KAAKZ,KAAMsB,EAAWkD,GAChCxE,KAAKsF,QAAUD,EAwBjB,MA5BAzB,GAASS,EAAmBe,GAO5Bf,EAAkBlC,UAAUoD,KAAO,SAAUV,GAC3CO,EAAUjD,UAAUoD,KAAK3E,KAAKZ,KAAM6E,GACpC7E,KAAKwF,gBAGPnB,EAAkBlC,UAAUsD,MAAQ,SAAUV,GAC5CK,EAAUjD,UAAUsD,MAAM7E,KAAKZ,KAAM+E,GACrC/E,KAAKwF,gBAGPnB,EAAkBlC,UAAUuD,UAAY,WACtCN,EAAUjD,UAAUuD,UAAU9E,KAAKZ,MACnCA,KAAKwF,gBAGPnB,EAAkBlC,UAAU+B,QAAU,WACpCkB,EAAUjD,UAAU+B,QAAQtD,KAAKZ,MACjCA,KAAKsF,SAAWtF,KAAKsF,QAAQpB,UAC7BlE,KAAKsF,QAAU,MAGVjB,GACNxB,GAWHX,GAAgByD,UAAY,SAAUrE,GACpC,GAAIsE,GAAS5F,IACb,OAAO,IAAIwC,GAAoB,SAAUgC,GACvC,MAAOoB,GAAOC,UAAU,GAAIxB,GAAkB/C,EAAWkD,KACxDoB,IAaL1D,EAAgB4D,YAAc,SAAUxE,GACtC,GAAIsE,GAAS5F,IACb,OAAO,IAAIwC,GAAoB,SAAUgC,GACvC,GAAIuB,GAAI,GAAIhD,GAA8BiD,EAAI,GAAIlD,EAKlD,OAJAkD,GAAEC,cAAcF,GAChBA,EAAEE,cAAc3E,EAAU8C,SAAS,WACjC4B,EAAEC,cAAc,GAAI5E,GAAoBC,EAAWsE,EAAOC,UAAUrB,QAE/DwB,GACNJ,IAgBL3D,EAAWiE,SAAW,SAAUC,EAAcC,EAAWC,EAASC,EAAgBhF,GAEhF,MADAuC,GAAYvC,KAAeA,EAAYiF,wBAChC,GAAI/D,GAAoB,SAAUgC,GACvC,GAAIgC,IAAQ,EAAMC,EAAQN,CAC1B,OAAO7E,GAAUoF,kBAAkB,SAAUC,GAC3C,GAAIC,GAAWC,CACf,KACML,EACFA,GAAQ,EAERC,EAAQJ,EAAQI,GAElBG,EAAYR,EAAUK,GAClBG,IACFC,EAASP,EAAeG,IAE1B,MAAOK,GAEP,WADAtC,GAASQ,QAAQ8B,GAGfF,GACFpC,EAASI,OAAOiC,GAChBF,KAEAnC,EAASU,mBAYjBjD,EAAW8E,MAAQ,SAAUC,EAAiBC,GAC5C,MAAO,IAAIzE,GAAoB,SAAUgC,GACvC,GAAkC0C,GAAUtB,EAAxCrE,EAAa2B,CACjB,KACEgE,EAAWF,IACXE,IAAa3F,EAAa2F,GAC1BtB,EAASqB,EAAkBC,GAC3B,MAAOJ,GACP,MAAO,IAAI9D,GAAoBV,EAAgBwE,GAAWjB,UAAUrB,GAAWjD,GAEjF,MAAO,IAAIyB,GAAoB4C,EAAOC,UAAUrB,GAAWjD,MAS/DW,EAAgBiF,IAAM,SAAUC,GAC9B,GAAIC,GAAarH,IACjB,OAAO,IAAIwC,GAAoB,SAAUgC,GAQvC,QAAS8C,KACFC,IACHA,EAASC,EACTC,EAAkBvD,WAItB,QAASwD,KACFH,IACHA,EAASI,EACTC,EAAiB1D,WAjBrB,GAAIqD,GACFC,EAAa,IAAKG,EAAc,IAChCC,EAAmB,GAAI7E,GACvB0E,EAAoB,GAAI1E,EAoD1B,OAlDAW,GAAU0D,KAAiBA,EAAcrD,EAAsBqD,IAgB/DQ,EAAiB3B,cAAcoB,EAAWxB,UAAU,SAAUgC,GAC5DP,IACIC,IAAWC,GACbhD,EAASI,OAAOiD,IAEjB,SAAU5C,GACXqC,IACIC,IAAWC,GACbhD,EAASQ,QAAQC,IAElB,WACDqC,IACIC,IAAWC,GACbhD,EAASU,iBAIbuC,EAAkBxB,cAAcmB,EAAYvB,UAAU,SAAUiC,GAC9DJ,IACIH,IAAWI,GACbnD,EAASI,OAAOkD,IAEjB,SAAU7C,GACXyC,IACIH,IAAWI,GACbnD,EAASQ,QAAQC,IAElB,WACDyC,IACIH,IAAWI,GACbnD,EAASU,iBAIN,GAAIlC,GAAoB4E,EAAkBH,MAWrDxF,EAAWkF,IAAM,WAGf,QAASY,GAAKC,EAAUC,GACtB,MAAOD,GAASb,IAAIc,GAEtB,IAAK,GALDC,GAAM9F,IACR+F,EAAQrH,EAAYsH,UAAW,GAIxBvG,EAAI,EAAGC,EAAMqG,EAAMlH,OAAYa,EAAJD,EAASA,IAC3CqG,EAAMH,EAAKG,EAAKC,EAAMtG,GAExB,OAAOqG,IAQThG,EAAgBmG,kBAAoB,SAAUC,GAC5C,IAAKA,EAAU,KAAM,IAAInD,OAAM,gCAC/B,OAAOkD,IAAmBrI,KAAMsI,IAWlC,IAAID,GAAoBpG,EAAWoG,kBAAoB,WACrD,GAAIE,GAAUzH,EAAYsH,UAAW,EACrC,OAAO,IAAI5F,GAAoB,SAAUgC,GACvC,GAAIgE,GAAM,EAAGC,EAAe,GAAI3F,GAChC4F,EAAarF,EAAmBqD,kBAAkB,SAAUC,GAC1D,GAAIsB,GAASjC,CACTwC,GAAMD,EAAQtH,QAChBgH,EAAUM,EAAQC,KAClB9E,EAAUuE,KAAaA,EAAUlE,EAAsBkE,IACvDjC,EAAI,GAAIjD,GACR0F,EAAaxC,cAAcD,GAC3BA,EAAEC,cAAcgC,EAAQpC,UAAUrB,EAASI,OAAO+D,KAAKnE,GAAWmC,EAAMA,KAExEnC,EAASU,eAGb,OAAO,IAAIlC,GAAoByF,EAAcC,KAmL/C,OArKFxG,GAAgB0G,gBAAkB,SAAUC,EAAOC,GAIjD,MAHoB,gBAATA,KACTA,EAAOD,GAEF7I,KAAK+I,gBAAgBF,EAAOC,GAAME,WAAW,SAAUC,GAC5D,MAAOA,GAAEC,YACRC,MAAM,SAAUF,GACjB,MAAOA,GAAEhI,OAAS,KAatBiB,EAAgB6G,gBAAkB,SAAUF,EAAOC,GACjD,GAAIlD,GAAS5F,IAGb,KAFC6I,IAAUA,EAAQ,GACCO,MAApBC,KAAKC,IAAIT,KAAwBA,EAAQ,GAC5B,GAATA,EAAc,KAAM,IAAI1D,OAAMlB,EAKlC,IAJQ,MAAR6E,IAAiBA,EAAOD,IACvBC,IAASA,EAAO,GACEM,MAAnBC,KAAKC,IAAIR,KAAuBA,EAAO,GAE3B,GAARA,EAAa,KAAM,IAAI3D,OAAMlB,EACjC,OAAO,IAAIzB,GAAoB,SAAUgC,GAMvC,QAAS+E,KACP,GAAIC,GAAI,GAAI9G,EACZ+G,GAAEC,KAAKF,GACPhF,EAASI,OAAOpB,EAAOgG,EAAGG,IAR5B,GAAI5D,GAAI,GAAIhD,GACV4G,EAAqB,GAAI1G,GAAmB8C,GAC5C6D,EAAI,EACJH,IA0BF,OAlBAF,KAEAxD,EAAEE,cAAcL,EAAOC,UACrB,SAAUoD,GACR,IAAK,GAAIpH,GAAI,EAAGC,EAAM2H,EAAExI,OAAYa,EAAJD,EAASA,IAAO4H,EAAE5H,GAAG+C,OAAOqE,EAC5D,IAAIY,GAAID,EAAIf,EAAQ,CACpBgB,IAAK,GAAKA,EAAIf,IAAS,GAAKW,EAAEK,QAAQ5E,gBACpC0E,EAAId,IAAS,GAAKS,KAEtB,SAAUxE,GACR,KAAO0E,EAAExI,OAAS,GAAKwI,EAAEK,QAAQ9E,QAAQD,EACzCP,GAASQ,QAAQD,IAEnB,WACE,KAAO0E,EAAExI,OAAS,GAAKwI,EAAEK,QAAQ5E,aACjCV,GAASU,iBAGNyE,GACN/D,IAYL1D,EAAgB6H,eAAiB,SAAUlB,GACzC,GAAIjD,GAAS5F,IACb,OAAO,IAAIwC,GAAoB,SAAUgC,GACvC,GAAIiF,KACJ,OAAO7D,GAAOC,UAAU,SAAUoD,GAChCQ,EAAEC,KAAKT,GACPQ,EAAExI,OAAS4H,GAASY,EAAEK,SACrBtF,EAASQ,QAAQ2D,KAAKnE,GAAW,WAClCA,EAASI,OAAO6E,GAChBjF,EAASU,iBAEVU,IAaH1D,EAAgB8H,eAAiB,SAAUC,GACzC,GAAIrE,GAAS5F,IAEb,OADAiK,KAAiBpK,IAAcoK,EAAe,MACvC,GAAIzH,GAAoB,SAAUgC,GACvC,GAAI0F,IAAQ,CACZ,OAAOtE,GAAOC,UAAU,SAAUoD,GAChCiB,GAAQ,EACR1F,EAASI,OAAOqE,IACfzE,EAASQ,QAAQ2D,KAAKnE,GAAW,YACjC0F,GAAS1F,EAASI,OAAOqF,GAC1BzF,EAASU,iBAEVlF,OAeP+B,EAAQI,UAAUuH,KAAO,SAAS7E,GAChC,GAAIsF,GAAoE,KAAzD1I,EAAqBzB,KAAKgC,IAAK6C,EAAO7E,KAAK4B,SAE1D,OADAuI,IAAYnK,KAAKgC,IAAI0H,KAAK7E,GACnBsF,GAeTjI,EAAgBkI,SAAW,SAAUC,EAAazI,GAChD,GAAIgE,GAAS5F,IAEb,OADA4B,KAAaA,EAAW0I,iBACjB,GAAI9H,GAAoB,SAAUgC,GACvC,GAAI+F,GAAU,GAAIxI,GAAQH,EAC1B,OAAOgE,GAAOC,UAAU,SAAUoD,GAChC,GAAIuB,GAAMvB,CAEV,IAAIoB,EACF,IACEG,EAAMH,EAAYpB,GAClB,MAAOlE,GAEP,WADAP,GAASQ,QAAQD,GAIrBwF,EAAQb,KAAKc,IAAQhG,EAASI,OAAOqE,IAEvCzE,EAASQ,QAAQ2D,KAAKnE,GACtBA,EAASU,YAAYyD,KAAKnE,KACzBxE,OAGIU"}