You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1 lines
11 KiB
1 lines
11 KiB
{"version":3,"file":"rx.coincidence.min.js","sources":["rx.coincidence.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","toArray","x","observableWindowWithOpenings","windowOpenings","windowClosingSelector","groupJoin","observableEmpty","_","win","observableWindowWithBoundaries","windowBoundaries","source","AnonymousObservable","observer","Subject","d","CompositeDisposable","r","RefCountDisposable","onNext","addRef","add","subscribe","err","onError","onCompleted","isPromise","observableFromPromise","w","observableWindowWithClosingSelector","createWindowClose","windowClose","m1","SingleAssignmentDisposable","m","setDisposable","take","noop","SerialDisposable","Observable","ObservableBase","AbstractObserver","internals","BinaryDisposable","observableProto","prototype","empty","observableNever","never","inherits","bindCallback","helpers","isFunction","fromPromise","tryCatch","fn","TypeError","Map","size","_values","_keys","key","i","indexOf","splice","get","set","push","forEach","cb","thisArg","join","right","leftDurationSelector","rightDurationSelector","resultSelector","left","o","group","leftDone","rightDone","leftId","rightId","leftMap","rightMap","handleError","id","md","duration","remove","v","result","s","buffer","flatMap","windowOpeningsOrClosingSelector","length","PairwiseObservable","__super__","subscribeCore","PairwiseObserver","_o","_p","_hp","next","error","completed","pairwise","partition","predicate","filter","groupBy","keySelector","elementSelector","groupByUntil","durationSelector","map","groupDisposable","refCountDisposable","item","fireNewMapEntry","writer","GroupedObservable","durationGroup","element","UnderlyingObservable","u","_m","_u","getDisposable","underlyingObservable","mergedDisposable","_subscribe"],"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,GAyBpC,QAASC,GAAcC,GACrB,MAAO,YACL,IACE,MAAOA,GAAeC,MAAMZ,KAAMa,WAClC,MAAOC,GAEP,MADAC,GAASD,EAAIA,EACNC,IA8Ob,QAASC,GAAQC,GAAK,MAAOA,GAAED,UA6B/B,QAASE,GAA6BC,EAAgBC,GACpD,MAAOD,GAAeE,UAAUrB,KAAMoB,EAAuBE,EAAiB,SAAUC,EAAGC,GACzF,MAAOA,KAIX,QAASC,GAA+BC,GACtC,GAAIC,GAAS3B,IACb,OAAO,IAAI4B,GAAoB,SAAUC,GACvC,GAAIL,GAAM,GAAIM,GACZC,EAAI,GAAIC,GACRC,EAAI,GAAIC,GAAmBH,EA4B7B,OA1BAF,GAASM,OAAOC,EAAOZ,EAAKS,IAE5BF,EAAEM,IAAIV,EAAOW,UAAU,SAAUrB,GAC/BO,EAAIW,OAAOlB,IACV,SAAUsB,GACXf,EAAIgB,QAAQD,GACZV,EAASW,QAAQD,IAChB,WACDf,EAAIiB,cACJZ,EAASY,iBAGXC,EAAUhB,KAAsBA,EAAmBiB,EAAsBjB,IAEzEK,EAAEM,IAAIX,EAAiBY,UAAU,SAAUM,GACzCpB,EAAIiB,cACJjB,EAAM,GAAIM,GACVD,EAASM,OAAOC,EAAOZ,EAAKS,KAC3B,SAAUM,GACXf,EAAIgB,QAAQD,GACZV,EAASW,QAAQD,IAChB,WACDf,EAAIiB,cACJZ,EAASY,iBAGJR,GACNN,GAGL,QAASkB,GAAoCzB,GAC3C,GAAIO,GAAS3B,IACb,OAAO,IAAI4B,GAAoB,SAAUC,GAgBvC,QAASiB,KACP,GAAIC,EACJ,KACEA,EAAc3B,IACd,MAAON,GAEP,WADAe,GAASW,QAAQ1B,GAInB4B,EAAUK,KAAiBA,EAAcJ,EAAsBI,GAE/D,IAAIC,GAAK,GAAIC,EACbC,GAAEC,cAAcH,GAChBA,EAAGG,cAAcJ,EAAYK,KAAK,GAAGd,UAAUe,EAAM,SAAUd,GAC7Df,EAAIgB,QAAQD,GACZV,EAASW,QAAQD,IAChB,WACDf,EAAIiB,cACJjB,EAAM,GAAIM,GACVD,EAASM,OAAOC,EAAOZ,EAAKS,IAC5Ba,OAnCJ,GAAII,GAAI,GAAII,GACVvB,EAAI,GAAIC,GAAoBkB,GAC5BjB,EAAI,GAAIC,GAAmBH,GAC3BP,EAAM,GAAIM,EAqCZ,OApCAD,GAASM,OAAOC,EAAOZ,EAAKS,IAC5BF,EAAEM,IAAIV,EAAOW,UAAU,SAAUrB,GAC7BO,EAAIW,OAAOlB,IACZ,SAAUsB,GACTf,EAAIgB,QAAQD,GACZV,EAASW,QAAQD,IAClB,WACCf,EAAIiB,cACJZ,EAASY,iBA2BbK,IACOb,GACNN,GA/XL,GAAI4B,GAAalD,EAAGkD,WAClBC,EAAiBnD,EAAGmD,eACpBC,EAAmBpD,EAAGqD,UAAUD,iBAChCzB,EAAsB3B,EAAG2B,oBACzB2B,EAAmBtD,EAAGsD,iBACtBzB,EAAqB7B,EAAG6B,mBACxBe,EAA6B5C,EAAG4C,2BAChCK,EAAmBjD,EAAGiD,iBACtBxB,EAAUzB,EAAGyB,QACb8B,EAAkBL,EAAWM,UAC7BvC,EAAkBiC,EAAWO,MAC7BC,EAAkBR,EAAWS,MAC7BpC,EAAsBvB,EAAGuB,oBACzBQ,EAAS/B,EAAGqD,UAAUtB,OACtB6B,EAAW5D,EAAGqD,UAAUO,SACxBC,EAAe7D,EAAGqD,UAAUQ,aAC5Bb,EAAOhD,EAAG8D,QAAQd,KAClBX,EAAYrC,EAAG8D,QAAQzB,UACvB0B,EAAa/D,EAAG8D,QAAQC,WACxBzB,EAAwBY,EAAWc,YAEjCtD,GAAYD,MAaZwD,EAAWjE,EAAGqD,UAAUY,SAAW,SAAkBC,GACvD,IAAKH,EAAWG,GAAO,KAAM,IAAIC,WAAU,wBAC3C,OAAO9D,GAAc6D,IAOnBE,EAAMxE,EAAKwE,KAAQ,WACrB,QAASA,KACPzE,KAAK0E,KAAO,EACZ1E,KAAK2E,WACL3E,KAAK4E,SAmCP,MAhCAH,GAAIZ,UAAU,UAAY,SAAUgB,GAClC,GAAIC,GAAI9E,KAAK4E,MAAMG,QAAQF,EAC3B,OAAU,KAANC,GAAmB,GACvB9E,KAAK2E,QAAQK,OAAOF,EAAG,GACvB9E,KAAK4E,MAAMI,OAAOF,EAAG,GACrB9E,KAAK0E,QACE,IAGTD,EAAIZ,UAAUoB,IAAM,SAAUJ,GAC5B,GAAIC,GAAI9E,KAAK4E,MAAMG,QAAQF,EAC3B,OAAa,KAANC,EAAWrE,EAAYT,KAAK2E,QAAQG,IAG7CL,EAAIZ,UAAUqB,IAAM,SAAUL,EAAK9F,GACjC,GAAI+F,GAAI9E,KAAK4E,MAAMG,QAAQF,EAQ3B,OAPU,KAANC,GACF9E,KAAK4E,MAAMO,KAAKN,GAChB7E,KAAK2E,QAAQQ,KAAKpG,GAClBiB,KAAK0E,QAEL1E,KAAK2E,QAAQG,GAAK/F,EAEbiB,MAGTyE,EAAIZ,UAAUuB,QAAU,SAAUC,EAAIC,GACpC,IAAK,GAAIR,GAAI,EAAGA,EAAI9E,KAAK0E,KAAMI,IAC7BO,EAAG9E,KAAK+E,EAAStF,KAAK2E,QAAQG,GAAI9E,KAAK4E,MAAME,KAI1CL,IAYTb,GAAgB2B,KAAO,SAAUC,EAAOC,EAAsBC,EAAuBC,GACnF,GAAIC,GAAO5F,IACX,OAAO,IAAI4B,GAAoB,SAAUiE,GACvC,GAAIC,GAAQ,GAAI9D,GACZ+D,GAAW,EAAOC,GAAY,EAC9BC,EAAS,EAAGC,EAAU,EACtBC,EAAU,GAAI1B,GAAO2B,EAAW,GAAI3B,GACpC4B,EAAc,SAAUvF,GAAK+E,EAAErD,QAAQ1B,GA+D3C,OA7DAgF,GAAMzD,IAAIuD,EAAKtD,UACb,SAAUvD,GACR,GAAIuH,GAAKL,IAAUM,EAAK,GAAItD,EAE5BkD,GAAQjB,IAAIoB,EAAIvH,GAChB+G,EAAMzD,IAAIkE,EAEV,IAAIC,GAAWlC,EAASmB,GAAsB1G,EAC9C,OAAIyH,KAAazF,EAAmB8E,EAAErD,QAAQgE,EAAS1F,IAEvDyF,EAAGpD,cAAcqD,EAASpD,KAAK,GAAGd,UAChCe,EACAgD,EACA,WACEF,EAAQ,UAAUG,IAAwB,IAAjBH,EAAQzB,MAAcqB,GAAYF,EAAEpD,cAC7DqD,EAAMW,OAAOF,UAGjBH,GAAShB,QAAQ,SAAUsB,GACzB,GAAIC,GAASrC,EAASqB,GAAgB5G,EAAO2H,EAC7C,OAAIC,KAAW5F,EAAmB8E,EAAErD,QAAQmE,EAAO7F,OACnD+E,GAAE1D,OAAOwE,OAGbN,EACA,WACEN,GAAW,GACVC,GAA8B,IAAjBG,EAAQzB,OAAemB,EAAEpD,iBAI3CqD,EAAMzD,IAAImD,EAAMlD,UACd,SAAUvD,GACR,GAAIuH,GAAKJ,IAAWK,EAAK,GAAItD,EAE7BmD,GAASlB,IAAIoB,EAAIvH,GACjB+G,EAAMzD,IAAIkE,EAEV,IAAIC,GAAWlC,EAASoB,GAAuB3G,EAC/C,OAAIyH,KAAazF,EAAmB8E,EAAErD,QAAQgE,EAAS1F,IAEvDyF,EAAGpD,cAAcqD,EAASpD,KAAK,GAAGd,UAChCe,EACAgD,EACA,WACED,EAAS,UAAUE,IAAyB,IAAlBF,EAAS1B,MAAcsB,GAAaH,EAAEpD,cAChEqD,EAAMW,OAAOF,UAGjBJ,GAAQf,QAAQ,SAAUsB,GACxB,GAAIC,GAASrC,EAASqB,GAAgBe,EAAG3H,EACzC,OAAI4H,KAAW5F,EAAmB8E,EAAErD,QAAQmE,EAAO7F,OACnD+E,GAAE1D,OAAOwE,OAGbN,EACA,WACEL,GAAY,GACXD,GAA8B,IAAlBK,EAAS1B,OAAemB,EAAEpD,iBAGpCqD,GACNF,IAYLhC,EAAgBvC,UAAY,SAAUmE,EAAOC,EAAsBC,EAAuBC,GACxF,GAAIC,GAAO5F,IACX,OAAO,IAAI4B,GAAoB,SAAUiE,GAOvC,QAASQ,GAAYvF,IANrB,GAAIgF,GAAQ,GAAI9D,GACZC,EAAI,GAAIC,GAAmB4D,GAC3BK,EAAU,GAAI1B,GAAO2B,EAAW,GAAI3B,GACpCwB,EAAS,EAAGC,EAAU,EACtBG,EAAc,SAAUvF,GAAK,MAAO,UAAU4F,GAAKA,EAAElE,QAAQ1B,IA+EjE,OA3EAgF,GAAMzD,IAAIuD,EAAKtD,UACb,SAAUvD,GACR,GAAI6H,GAAI,GAAI9E,GACRwE,EAAKL,GACTE,GAAQjB,IAAIoB,EAAIM,EAEhB,IAAID,GAASrC,EAASqB,GAAgB5G,EAAOqD,EAAOwE,EAAG3E,GACvD,IAAI0E,IAAW5F,EAEb,MADAoF,GAAQf,QAAQiB,EAAYM,EAAO7F,IAC5B+E,EAAErD,QAAQmE,EAAO7F,EAE1B+E,GAAE1D,OAAOwE,GAETP,EAAShB,QAAQ,SAAUsB,GAAKE,EAAEzE,OAAOuE,IAEzC,IAAIH,GAAK,GAAItD,EACb6C,GAAMzD,IAAIkE,EAEV,IAAIC,GAAWlC,EAASmB,GAAsB1G,EAC9C,OAAIyH,KAAazF,GACfoF,EAAQf,QAAQiB,EAAYG,EAAS1F,IAC9B+E,EAAErD,QAAQgE,EAAS1F,QAG5ByF,GAAGpD,cAAcqD,EAASpD,KAAK,GAAGd,UAChCe,EACA,SAAUvC,GACRqF,EAAQf,QAAQiB,EAAYvF,IAC5B+E,EAAErD,QAAQ1B,IAEZ,WACEqF,EAAQ,UAAUG,IAAOM,EAAEnE,cAC3BqD,EAAMW,OAAOF,OAGnB,SAAUzF,GACRqF,EAAQf,QAAQiB,EAAYvF,IAC5B+E,EAAErD,QAAQ1B,IAEZ,WAAc+E,EAAEpD,iBAGlBqD,EAAMzD,IAAImD,EAAMlD,UACd,SAAUvD,GACR,GAAIuH,GAAKJ,GACTE,GAASlB,IAAIoB,EAAIvH,EAEjB,IAAIwH,GAAK,GAAItD,EACb6C,GAAMzD,IAAIkE,EAEV,IAAIC,GAAWlC,EAASoB,GAAuB3G,EAC/C,OAAIyH,KAAazF,GACfoF,EAAQf,QAAQiB,EAAYG,EAAS1F,IAC9B+E,EAAErD,QAAQgE,EAAS1F,KAG5ByF,EAAGpD,cAAcqD,EAASpD,KAAK,GAAGd,UAChCe,EACA,SAAUvC,GACRqF,EAAQf,QAAQiB,EAAYvF,IAC5B+E,EAAErD,QAAQ1B,IAEZ,WACEsF,EAAS,UAAUE,GACnBR,EAAMW,OAAOF,UAGjBJ,GAAQf,QAAQ,SAAUsB,GAAKA,EAAEvE,OAAOpD,OAE1C,SAAU+B,GACRqF,EAAQf,QAAQiB,EAAYvF,IAC5B+E,EAAErD,QAAQ1B,MAIPmB,GACN2D,IAWLhC,EAAgBiD,OAAS,WACvB,MAAO7G,MAAKF,OAAOc,MAAMZ,KAAMa,WAC5BiG,QAAQ9F,IAUb4C,EAAgB9D,OAAS,SAAUiH,EAAiC3F,GAClE,MAAyB,KAArBP,UAAUmG,QAAwC,kBAAjBnG,WAAU,GACtCY,EAA+BlB,KAAKP,KAAM+G,GAED,kBAApCA,GACZlE,EAAoCtC,KAAKP,KAAM+G,GAC/C7F,EAA6BX,KAAKP,KAAM+G,EAAiC3F,GA6F7E,IAAI6F,GAAsB,SAAUC,GAElC,QAASD,GAAmBtF,GAC1B3B,KAAK2B,OAASA,EACduF,EAAU3G,KAAKP,MAOjB,MAVAiE,GAASgD,EAAoBC,GAM7BD,EAAmBpD,UAAUsD,cAAgB,SAAUtB,GACrD,MAAO7F,MAAK2B,OAAOW,UAAU,GAAI8E,GAAiBvB,KAG7CoB,GACPzD,GAEE4D,EAAoB,SAASF,GAE/B,QAASE,GAAiBvB,GACxB7F,KAAKqH,GAAKxB,EACV7F,KAAKsH,GAAK,KACVtH,KAAKuH,KAAM,EACXL,EAAU3G,KAAKP,MAcjB,MAnBAiE,GAASmD,EAAkBF,GAQ3BE,EAAiBvD,UAAU2D,KAAO,SAAUvG,GACtCjB,KAAKuH,IACPvH,KAAKqH,GAAGlF,QAAQnC,KAAKsH,GAAIrG,IAEzBjB,KAAKuH,KAAM,EAEbvH,KAAKsH,GAAKrG,GAEZmG,EAAiBvD,UAAU4D,MAAQ,SAAUlF,GAAOvC,KAAKqH,GAAG7E,QAAQD,IACpE6E,EAAiBvD,UAAU6D,UAAY,WAAc1H,KAAKqH,GAAG5E,eAEtD2E,GACP3D,EAQFG,GAAgB+D,SAAW,WACzB,MAAO,IAAIV,GAAmBjH,OAgBhC4D,EAAgBgE,UAAY,SAASC,EAAWvC,GAC9C,GAAIf,GAAKL,EAAa2D,EAAWvC,EAAS,EAC1C,QACEtF,KAAK8H,OAAOD,EAAWvC,GACvBtF,KAAK8H,OAAO,SAAU7G,EAAG6D,EAAGe,GAAK,OAAQtB,EAAGtD,EAAG6D,EAAGe,OAetDjC,EAAgBmE,QAAU,SAAUC,EAAaC,GAC/C,MAAOjI,MAAKkI,aAAaF,EAAaC,EAAiBlE,IAmBvDH,EAAgBsE,aAAe,SAAUF,EAAaC,EAAiBE,GACrE,GAAIxG,GAAS3B,IACb,OAAO,IAAI4B,GAAoB,SAAUiE,GACvC,GAAIuC,GAAM,GAAI3D,GACZ4D,EAAkB,GAAIrG,GACtBsG,EAAqB,GAAIpG,GAAmBmG,GAC5ChC,EAAc,SAAUvF,GAAK,MAAO,UAAUyH,GAAQA,EAAK/F,QAAQ1B,IA6DvE,OA3DEuH,GAAgBhG,IACdV,EAAOW,UAAU,SAAUrB,GACzB,GAAI4D,GAAMP,EAAS0D,GAAa/G,EAChC,IAAI4D,IAAQ9D,EAEV,MADAqH,GAAIhD,QAAQiB,EAAYxB,EAAI/D,IACrB+E,EAAErD,QAAQqC,EAAI/D,EAGvB,IAAI0H,IAAkB,EAAOC,EAASL,EAAInD,IAAIJ,EAO9C,IANI4D,IAAWhI,IACbgI,EAAS,GAAI3G,GACbsG,EAAIlD,IAAIL,EAAK4D,GACbD,GAAkB,GAGhBA,EAAiB,CACnB,GAAI1C,GAAQ,GAAI4C,GAAkB7D,EAAK4D,EAAQH,GAC7CK,EAAgB,GAAID,GAAkB7D,EAAK4D,GACzCjC,EAAWlC,EAAS6D,GAAkBQ,EAC1C,IAAInC,IAAazF,EAEf,MADAqH,GAAIhD,QAAQiB,EAAYG,EAAS1F,IAC1B+E,EAAErD,QAAQgE,EAAS1F,EAG5B+E,GAAE1D,OAAO2D,EAET,IAAIS,GAAK,GAAItD,EACboF,GAAgBhG,IAAIkE,GAEpBA,EAAGpD,cAAcqD,EAASpD,KAAK,GAAGd,UAChCe,EACA,SAAUvC,GACRsH,EAAIhD,QAAQiB,EAAYvF,IACxB+E,EAAErD,QAAQ1B,IAEZ,WACMsH,EAAI,UAAUvD,IAAQ4D,EAAOhG,cACjC4F,EAAgB5B,OAAOF,MAI7B,GAAIqC,GAAU3H,CACd,OAAImD,GAAW6D,KACbW,EAAUtE,EAAS2D,GAAiBhH,GAChC2H,IAAY7H,IACdqH,EAAIhD,QAAQiB,EAAYuC,EAAQ9H,IACzB+E,EAAErD,QAAQoG,EAAQ9H,QAI7B2H,GAAOtG,OAAOyG,IACf,SAAU9H,GACXsH,EAAIhD,QAAQiB,EAAYvF,IACxB+E,EAAErD,QAAQ1B,IACT,WACDsH,EAAIhD,QAAQ,SAAUmD,GAAQA,EAAK9F,gBACnCoD,EAAEpD,iBAGC6F,GACN3G,GAGL,IAAIkH,GAAwB,SAAU3B,GAEpC,QAAS2B,GAAqB3F,EAAG4F,GAC/B9I,KAAK+I,GAAK7F,EACVlD,KAAKgJ,GAAKF,EACV5B,EAAU3G,KAAKP,MAOjB,MAXAiE,GAAS4E,EAAsB3B,GAO/B2B,EAAqBhF,UAAUsD,cAAgB,SAAUtB,GACvD,MAAO,IAAIlC,GAAiB3D,KAAK+I,GAAGE,gBAAiBjJ,KAAKgJ,GAAG1G,UAAUuD,KAGlEgD,GACPrF,GAEEkF,EAAqB,SAAUxB,GAEjC,QAASwB,GAAkB7D,EAAKqE,EAAsBC,GACpDjC,EAAU3G,KAAKP,MACfA,KAAK6E,IAAMA,EACX7E,KAAKkJ,qBAAwBC,EAE3B,GAAIN,GAAqBM,EAAkBD,GAD3CA,EAQJ,MAbAjF,GAASyE,EAAmBxB,GAS5BwB,EAAkB7E,UAAUuF,WAAa,SAAUvD,GACjD,MAAO7F,MAAKkJ,qBAAqB5G,UAAUuD,IAGtC6C,GACPnF,EAEF,OAAOlD"} |