{"version":3,"file":"rx.joinpatterns.min.js","sources":["rx.joinpatterns.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","Pattern","patterns","Plan","expression","selector","planCreateObserver","externalSubscriptions","observable","onError","entry","get","observer","JoinObserver","set","ActivePlan","joinObserverArray","onNext","onCompleted","joinObservers","Map","i","len","length","joinObserver","Observable","observableProto","prototype","AnonymousObservable","observableThrow","throwError","observerCreate","Observer","create","SingleAssignmentDisposable","CompositeDisposable","AbstractObserver","internals","noop","helpers","inherits","isEqual","Enumerable","Enumerator","iterator","doneEnumerator","_keys","_values","key","indexOf","value","push","forEach","callback","thisArg","and","other","concat","thenDo","activate","deactivate","self","bind","activePlan","result","apply","arguments","e","j","jlen","removeActivePlan","addActivePlan","dequeue","v","queue","shift","match","hasValues","firstValues","isCompleted","kind","values","__super__","source","activePlans","subscription","isDisposed","JoinObserverPrototype","next","notification","exception","slice","error","completed","subscribe","setDisposable","materialize","splice","dispose","right","when","plans","Array","isArray","o","outObserver","x","err","idx","group","add"],"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,GAmDpC,QAASiB,GAAQC,GACff,KAAKe,SAAWA,EAqBlB,QAASC,GAAKC,EAAYC,GACtBlB,KAAKiB,WAAaA,EAClBjB,KAAKkB,SAAWA,EA8BpB,QAASC,GAAmBC,EAAuBC,EAAYC,GAC7D,GAAIC,GAAQH,EAAsBI,IAAIH,EACtC,KAAKE,EAAO,CACV,GAAIE,GAAW,GAAIC,GAAaL,EAAYC,EAE5C,OADAF,GAAsBO,IAAIN,EAAYI,GAC/BA,EAET,MAAOF,GAGT,QAASK,GAAWC,EAAmBC,EAAQC,GAC7C/B,KAAK6B,kBAAoBA,EACzB7B,KAAK8B,OAASA,EACd9B,KAAK+B,YAAcA,EACnB/B,KAAKgC,cAAgB,GAAIC,EACzB,KAAK,GAAIC,GAAI,EAAGC,EAAMnC,KAAK6B,kBAAkBO,OAAYD,EAAJD,EAASA,IAAK,CACjE,GAAIG,GAAerC,KAAK6B,kBAAkBK,EAC1ClC,MAAKgC,cAAcL,IAAIU,EAAcA,IAvHzC,GAAIC,GAAa5B,EAAG4B,WAClBC,EAAkBD,EAAWE,UAC7BC,EAAsB/B,EAAG+B,oBACzBC,EAAkBJ,EAAWK,WAC7BC,EAAiBlC,EAAGmC,SAASC,OAC7BC,EAA6BrC,EAAGqC,2BAChCC,EAAsBtC,EAAGsC,oBACzBC,EAAmBvC,EAAGwC,UAAUD,iBAChCE,EAAOzC,EAAG0C,QAAQD,KAElBE,GADkB3C,EAAGwC,UAAUI,QACpB5C,EAAGwC,UAAUG,UAOtBpB,GANWvB,EAAGwC,UAAUK,WACb7C,EAAGwC,UAAUM,WACb9C,EAAG+C,SACC/C,EAAGgD,eAGZ5D,EAAKmC,KAAQ,WAErB,QAASA,KACPjC,KAAK2D,SACL3D,KAAK4D,WAoBP,MAjBA3B,GAAIO,UAAUhB,IAAM,SAAUqC,GAC5B,GAAI3B,GAAIlC,KAAK2D,MAAMG,QAAQD,EAC3B,OAAa,KAAN3B,EAAWlC,KAAK4D,QAAQ1B,GAAKrC,GAGtCoC,EAAIO,UAAUb,IAAM,SAAUkC,EAAKE,GACjC,GAAI7B,GAAIlC,KAAK2D,MAAMG,QAAQD,EACrB,MAAN3B,IAAalC,KAAK4D,QAAQ1B,GAAK6B,GAC/B/D,KAAK4D,QAAQ5D,KAAK2D,MAAMK,KAAKH,GAAO,GAAKE,GAG3C9B,EAAIO,UAAUyB,QAAU,SAAUC,EAAUC,GAC1C,IAAK,GAAIjC,GAAI,EAAGC,EAAMnC,KAAK2D,MAAMvB,OAAYD,EAAJD,EAASA,IAChDgC,EAAStD,KAAKuD,EAASnE,KAAK4D,QAAQ1B,GAAIlC,KAAK2D,MAAMzB,KAIhDD,KAgBTnB,GAAQ0B,UAAU4B,IAAM,SAAUC,GAChC,MAAO,IAAIvD,GAAQd,KAAKe,SAASuD,OAAOD,KAQ1CvD,EAAQ0B,UAAU+B,OAAS,SAAUrD,GACnC,MAAO,IAAIF,GAAKhB,KAAMkB,IAQxBF,EAAKwB,UAAUgC,SAAW,SAAUpD,EAAuBK,EAAUgD,GAGnE,IAAK,GAFDC,GAAO1E,KACPgC,KACKE,EAAI,EAAGC,EAAMnC,KAAKiB,WAAWF,SAASqB,OAAYD,EAAJD,EAASA,IAC9DF,EAAcgC,KAAK7C,EAAmBC,EAAuBpB,KAAKiB,WAAWF,SAASmB,GAAIT,EAASH,QAAQqD,KAAKlD,IAElH,IAAImD,GAAa,GAAIhD,GAAWI,EAAe,WAC7C,GAAI6C,EACJ,KACEA,EAASH,EAAKxD,SAAS4D,MAAMJ,EAAMK,WACnC,MAAOC,GAEP,WADAvD,GAASH,QAAQ0D,GAGnBvD,EAASK,OAAO+C,IACf,WACD,IAAK,GAAII,GAAI,EAAGC,EAAOlD,EAAcI,OAAY8C,EAAJD,EAAUA,IACrDjD,EAAciD,GAAGE,iBAAiBP,EAEpCH,GAAWG,IAEb,KAAK1C,EAAI,EAAGC,EAAMH,EAAcI,OAAYD,EAAJD,EAASA,IAC/CF,EAAcE,GAAGkD,cAAcR,EAEjC,OAAOA,IAwBThD,EAAWY,UAAU6C,QAAU,WAC7BrF,KAAKgC,cAAciC,QAAQ,SAAUqB,GAAKA,EAAEC,MAAMC,WAGpD5D,EAAWY,UAAUiD,MAAQ,WAC3B,GAAIvD,GAAGC,EAAKuD,GAAY,CACxB,KAAKxD,EAAI,EAAGC,EAAMnC,KAAK6B,kBAAkBO,OAAYD,EAAJD,EAASA,IACxD,GAA+C,IAA3ClC,KAAK6B,kBAAkBK,GAAGqD,MAAMnD,OAAc,CAChDsD,GAAY,CACZ,OAGJ,GAAIA,EAAW,CACb,GAAIC,MACAC,GAAc,CAClB,KAAK1D,EAAI,EAAGC,EAAMnC,KAAK6B,kBAAkBO,OAAYD,EAAJD,EAASA,IACxDyD,EAAY3B,KAAKhE,KAAK6B,kBAAkBK,GAAGqD,MAAM,IACL,MAA5CvF,KAAK6B,kBAAkBK,GAAGqD,MAAM,GAAGM,OAAiBD,GAAc,EAEpE,IAAIA,EACF5F,KAAK+B,kBACA,CACL/B,KAAKqF,SACL,IAAIS,KACJ,KAAK5D,EAAI,EAAGC,EAAMwD,EAAYvD,OAAQF,EAAIyD,EAAYvD,OAAQF,IAC5D4D,EAAO9B,KAAK2B,EAAYzD,GAAG6B,MAE7B/D,MAAK8B,OAAOgD,MAAM9E,KAAM8F,KAK9B,IAAIpE,GAAgB,SAAUqE,GAG5B,QAASrE,GAAasE,EAAQ1E,GAC5ByE,EAAUnF,KAAKZ,MACfA,KAAKgG,OAASA,EACdhG,KAAKsB,QAAUA,EACftB,KAAKuF,SACLvF,KAAKiG,eACLjG,KAAKkG,aAAe,GAAInD,GACxB/C,KAAKmG,YAAa,EATpB9C,EAAS3B,EAAcqE,EAYvB,IAAIK,GAAwB1E,EAAac,SAuCzC,OArCA4D,GAAsBC,KAAO,SAAUC,GACrC,IAAKtG,KAAKmG,WAAY,CACpB,GAA0B,MAAtBG,EAAaT,KACf,MAAO7F,MAAKsB,QAAQgF,EAAaC,UAEnCvG,MAAKuF,MAAMvB,KAAKsC,EAEhB,KAAK,GADDL,GAAcjG,KAAKiG,YAAYO,MAAM,GAChCtE,EAAI,EAAGC,EAAM8D,EAAY7D,OAAYD,EAAJD,EAASA,IACjD+D,EAAY/D,GAAGuD,UAKrBW,EAAsBK,MAAQtD,EAC9BiD,EAAsBM,UAAYvD,EAElCiD,EAAsBhB,cAAgB,SAAUR,GAC9C5E,KAAKiG,YAAYjC,KAAKY,IAGxBwB,EAAsBO,UAAY,WAChC3G,KAAKkG,aAAaU,cAAc5G,KAAKgG,OAAOa,cAAcF,UAAU3G,QAGtEoG,EAAsBjB,iBAAmB,SAAUP,GACjD5E,KAAKiG,YAAYa,OAAO9G,KAAKiG,YAAYnC,QAAQc,GAAa,GAClC,IAA5B5E,KAAKiG,YAAY7D,QAAgBpC,KAAK+G,WAGxCX,EAAsBW,QAAU,WAC9BhB,EAAUvD,UAAUuE,QAAQnG,KAAKZ,MAC5BA,KAAKmG,aACRnG,KAAKmG,YAAa,EAClBnG,KAAKkG,aAAaa,YAIfrF,GACNuB,EAoED,OA5DFV,GAAgB6B,IAAM,SAAU4C,GAC9B,MAAO,IAAIlG,IAASd,KAAMgH,KAS5BzE,EAAgBgC,OAAS,SAAUrD,GACjC,MAAO,IAAIJ,IAASd,OAAOuE,OAAOrD,IASpCoB,EAAW2E,KAAO,WAChB,GAA4BC,GAAxB/E,EAAM4C,UAAU3C,MACpB,IAAI+E,MAAMC,QAAQrC,UAAU,IAC1BmC,EAAQnC,UAAU,OACb,CACLmC,EAAQ,GAAIC,OAAMhF,EAClB,KAAI,GAAID,GAAI,EAAOC,EAAJD,EAASA,IAAOgF,EAAMhF,GAAK6C,UAAU7C,GAEtD,MAAO,IAAIO,GAAoB,SAAU4E,GACvC,GAAIpB,MACA7E,EAAwB,GAAIa,GAC5BqF,EAAc1E,EAChB,SAAU2E,GAAKF,EAAEvF,OAAOyF,IACxB,SAAUC,GACRpG,EAAsB6C,QAAQ,SAAUqB,GAAKA,EAAEhE,QAAQkG,KACvDH,EAAE/F,QAAQkG,IAEZ,WAAeH,EAAEtF,eAEnB,KACE,IAAK,GAAIG,GAAI,EAAGC,EAAM+E,EAAM9E,OAAYD,EAAJD,EAASA,IAC3C+D,EAAYjC,KAAKkD,EAAMhF,GAAGsC,SAASpD,EAAuBkG,EAAa,SAAU1C,GAC/E,GAAI6C,GAAMxB,EAAYnC,QAAQc,EAC9BqB,GAAYa,OAAOW,EAAK,GACD,IAAvBxB,EAAY7D,QAAgBiF,EAAEtF,iBAGlC,MAAOiD,GACPtC,EAAgBsC,GAAG2B,UAAUU,GAE/B,GAAIK,GAAQ,GAAI1E,EAMhB,OALA5B,GAAsB6C,QAAQ,SAAU5B,GACtCA,EAAasE,YACbe,EAAMC,IAAItF,KAGLqF,KAIFhH"}