| 1 | {"version":3,"file":"rx.joinpatterns.min.js","sources":["rx.joinpatterns.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","Pattern","patterns","Plan","expression","selector","handleOnError","o","onError","handleOnNext","observer","result","tryCatch","onNext","planCreateObserver","externalSubscriptions","observable","entry","get","JoinObserver","set","ActivePlan","joinObserverArray","onCompleted","joinObservers","Map","i","len","length","joinObserver","Observable","observableProto","prototype","AnonymousObservable","observableThrow","throwError","observerCreate","Observer","create","SingleAssignmentDisposable","CompositeDisposable","AbstractObserver","internals","noop","helpers","inherits","isFunction","fn","TypeError","size","_values","_keys","key","indexOf","splice","push","forEach","cb","thisArg","and","other","concat","thenDo","activate","deactivate","errHandler","activePlan","j","jlen","removeActivePlan","addActivePlan","dequeue","v","queue","shift","match","hasValues","firstValues","isCompleted","kind","values","__super__","source","activePlans","subscription","isDisposed","JoinObserverPrototype","next","notification","error","slice","completed","subscribe","setDisposable","materialize","dispose","right","when","plans","Array","isArray","outObserver","x","err","idx","group","add"],"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,GAiBpC,QAASC,GAAcC,GACrB,MAAO,YACL,IACE,MAAOA,GAAeC,MAAMZ,KAAMa,WAClC,MAAOC,GAEP,MADAC,GAASD,EAAIA,EACNC,IA4Db,QAASC,GAAQC,GACfjB,KAAKiB,SAAWA,EAqBlB,QAASC,GAAKC,EAAYC,GACxBpB,KAAKmB,WAAaA,EAClBnB,KAAKoB,SAAWA,EAGlB,QAASC,GAAcC,GAAK,MAAO,UAAUR,GAAKQ,EAAEC,QAAQT,IAC5D,QAASU,GAAa5B,EAAM6B,GAC1B,MAAO,YACL,GAAIC,GAASC,EAAS/B,EAAKwB,UAAUR,MAAMhB,EAAMiB,UACjD,OAAIa,KAAWX,EAAmBU,EAASF,QAAQG,EAAOZ,OAC1DW,GAASG,OAAOF,IAqBpB,QAASG,GAAmBC,EAAuBC,EAAYR,GAC7D,GAAIS,GAAQF,EAAsBG,IAAIF,EACtC,KAAKC,EAAO,CACV,GAAIP,GAAW,GAAIS,GAAaH,EAAYR,EAE5C,OADAO,GAAsBK,IAAIJ,EAAYN,GAC/BA,EAET,MAAOO,GAGT,QAASI,GAAWC,EAAmBT,EAAQU,GAC7CtC,KAAKqC,kBAAoBA,EACzBrC,KAAK4B,OAASA,EACd5B,KAAKsC,YAAcA,EACnBtC,KAAKuC,cAAgB,GAAIC,EACzB,KAAK,GAAIC,GAAI,EAAGC,EAAM1C,KAAKqC,kBAAkBM,OAAYD,EAAJD,EAASA,IAAK,CACjE,GAAIG,GAAe5C,KAAKqC,kBAAkBI,EAC1CzC,MAAKuC,cAAcJ,IAAIS,EAAcA,IAtJzC,GAAIC,GAAaxC,EAAGwC,WAClBC,EAAkBD,EAAWE,UAC7BC,EAAsB3C,EAAG2C,oBACzBC,EAAkBJ,EAAWK,WAC7BC,EAAiB9C,EAAG+C,SAASC,OAC7BC,EAA6BjD,EAAGiD,2BAChCC,EAAsBlD,EAAGkD,oBACzBC,EAAmBnD,EAAGoD,UAAUD,iBAChCE,EAAOrD,EAAGsD,QAAQD,KAClBE,EAAWvD,EAAGoD,UAAUG,SACxBC,EAAaxD,EAAGsD,QAAQE,WAEtB9C,GAAYD,MAaZa,EAAWtB,EAAGoD,UAAU9B,SAAW,SAAkBmC,GACvD,IAAKD,EAAWC,GAAO,KAAM,IAAIC,WAAU,wBAC3C,OAAOrD,GAAcoD,IAOnBtB,EAAMvC,EAAKuC,KAAQ,WACrB,QAASA,KACPxC,KAAKgE,KAAO,EACZhE,KAAKiE,WACLjE,KAAKkE,SAmCP,MAhCA1B,GAAIO,UAAU,UAAY,SAAUoB,GAClC,GAAI1B,GAAIzC,KAAKkE,MAAME,QAAQD,EAC3B,OAAU,KAAN1B,GAAmB,GACvBzC,KAAKiE,QAAQI,OAAO5B,EAAG,GACvBzC,KAAKkE,MAAMG,OAAO5B,EAAG,GACrBzC,KAAKgE,QACE,IAGTxB,EAAIO,UAAUd,IAAM,SAAUkC,GAC5B,GAAI1B,GAAIzC,KAAKkE,MAAME,QAAQD,EAC3B,OAAa,KAAN1B,EAAWhC,EAAYT,KAAKiE,QAAQxB,IAG7CD,EAAIO,UAAUZ,IAAM,SAAUgC,EAAKpF,GACjC,GAAI0D,GAAIzC,KAAKkE,MAAME,QAAQD,EAQ3B,OAPU,KAAN1B,GACFzC,KAAKkE,MAAMI,KAAKH,GAChBnE,KAAKiE,QAAQK,KAAKvF,GAClBiB,KAAKgE,QAELhE,KAAKiE,QAAQxB,GAAK1D,EAEbiB,MAGTwC,EAAIO,UAAUwB,QAAU,SAAUC,EAAIC,GACpC,IAAK,GAAIhC,GAAI,EAAGA,EAAIzC,KAAKgE,KAAMvB,IAC7B+B,EAAGjE,KAAKkE,EAASzE,KAAKiE,QAAQxB,GAAIzC,KAAKkE,MAAMzB,KAI1CD,IAgBTxB,GAAQ+B,UAAU2B,IAAM,SAAUC,GAChC,MAAO,IAAI3D,GAAQhB,KAAKiB,SAAS2D,OAAOD,KAQ1C3D,EAAQ+B,UAAU8B,OAAS,SAAUzD,GACnC,MAAO,IAAIF,GAAKlB,KAAMoB,IAiBxBF,EAAK6B,UAAU+B,SAAW,SAAUhD,EAAuBL,EAAUsD,GAEnE,IAAK,GADDxC,MAAoByC,EAAa3D,EAAcI,GAC1CgB,EAAI,EAAGC,EAAM1C,KAAKmB,WAAWF,SAAS0B,OAAYD,EAAJD,EAASA,IAC9DF,EAAc+B,KAAKzC,EAAmBC,EAAuB9B,KAAKmB,WAAWF,SAASwB,GAAIuC,GAE5F,IAAIC,GAAa,GAAI7C,GAAWG,EAAef,EAAaxB,KAAMyB,GAAW,WAC3E,IAAK,GAAIyD,GAAI,EAAGC,EAAO5C,EAAcI,OAAYwC,EAAJD,EAAUA,IACrD3C,EAAc2C,GAAGE,iBAAiBH,EAEpCF,GAAWE,IAEb,KAAKxC,EAAI,EAAGC,EAAMH,EAAcI,OAAYD,EAAJD,EAASA,IAC/CF,EAAcE,GAAG4C,cAAcJ,EAEjC,OAAOA,IAwBT7C,EAAWW,UAAUuC,QAAU,WAC7BtF,KAAKuC,cAAcgC,QAAQ,SAAUgB,GAAKA,EAAEC,MAAMC,WAGpDrD,EAAWW,UAAU2C,MAAQ,WAC3B,GAAIjD,GAAGC,EAAKiD,GAAY,CACxB,KAAKlD,EAAI,EAAGC,EAAM1C,KAAKqC,kBAAkBM,OAAYD,EAAJD,EAASA,IACxD,GAA+C,IAA3CzC,KAAKqC,kBAAkBI,GAAG+C,MAAM7C,OAAc,CAChDgD,GAAY,CACZ,OAGJ,GAAIA,EAAW,CACb,GAAIC,MACAC,GAAc,CAClB,KAAKpD,EAAI,EAAGC,EAAM1C,KAAKqC,kBAAkBM,OAAYD,EAAJD,EAASA,IACxDmD,EAAYtB,KAAKtE,KAAKqC,kBAAkBI,GAAG+C,MAAM,IACL,MAA5CxF,KAAKqC,kBAAkBI,GAAG+C,MAAM,GAAGM,OAAiBD,GAAc,EAEpE,IAAIA,EACF7F,KAAKsC,kBACA,CACLtC,KAAKsF,SACL,IAAIS,KACJ,KAAKtD,EAAI,EAAGC,EAAMkD,EAAYjD,OAAQF,EAAImD,EAAYjD,OAAQF,IAC5DsD,EAAOzB,KAAKsB,EAAYnD,GAAG1D,MAE7BiB,MAAK4B,OAAOhB,MAAMZ,KAAM+F,KAK9B,IAAI7D,GAAgB,SAAU8D,GAG5B,QAAS9D,GAAa+D,EAAQ1E,GAC5ByE,EAAUzF,KAAKP,MACfA,KAAKiG,OAASA,EACdjG,KAAKuB,QAAUA,EACfvB,KAAKwF,SACLxF,KAAKkG,eACLlG,KAAKmG,aAAe,GAAI7C,GACxBtD,KAAKoG,YAAa,EATpBxC,EAAS1B,EAAc8D,EAYvB,IAAIK,GAAwBnE,EAAaa,SAuCzC,OArCAsD,GAAsBC,KAAO,SAAUC,GACrC,IAAKvG,KAAKoG,WAAY,CACpB,GAA0B,MAAtBG,EAAaT,KACf,MAAO9F,MAAKuB,QAAQgF,EAAaC,MAEnCxG,MAAKwF,MAAMlB,KAAKiC,EAEhB,KAAK,GADDL,GAAclG,KAAKkG,YAAYO,MAAM,GAChChE,EAAI,EAAGC,EAAMwD,EAAYvD,OAAYD,EAAJD,EAASA,IACjDyD,EAAYzD,GAAGiD,UAKrBW,EAAsBG,MAAQ9C,EAC9B2C,EAAsBK,UAAYhD,EAElC2C,EAAsBhB,cAAgB,SAAUJ,GAC9CjF,KAAKkG,YAAY5B,KAAKW,IAGxBoB,EAAsBM,UAAY,WAChC3G,KAAKmG,aAAaS,cAAc5G,KAAKiG,OAAOY,cAAcF,UAAU3G,QAGtEqG,EAAsBjB,iBAAmB,SAAUH,GACjDjF,KAAKkG,YAAY7B,OAAOrE,KAAKkG,YAAY9B,QAAQa,GAAa,GAClC,IAA5BjF,KAAKkG,YAAYvD,QAAgB3C,KAAK8G,WAGxCT,EAAsBS,QAAU,WAC9Bd,EAAUjD,UAAU+D,QAAQvG,KAAKP,MAC5BA,KAAKoG,aACRpG,KAAKoG,YAAa,EAClBpG,KAAKmG,aAAaW,YAIf5E,GACNsB,EAoEH,OA5DAV,GAAgB4B,IAAM,SAAUqC,GAC9B,MAAO,IAAI/F,IAAShB,KAAM+G,KAS5BjE,EAAgB+B,OAAS,SAAUzD,GACjC,MAAO,IAAIJ,IAAShB,OAAO6E,OAAOzD,IASpCyB,EAAWmE,KAAO,WAChB,GAA4BC,GAAxBvE,EAAM7B,UAAU8B,MACpB,IAAIuE,MAAMC,QAAQtG,UAAU,IAC1BoG,EAAQpG,UAAU,OACb,CACLoG,EAAQ,GAAIC,OAAMxE,EAClB,KAAI,GAAID,GAAI,EAAOC,EAAJD,EAASA,IAAOwE,EAAMxE,GAAK5B,UAAU4B,GAEtD,MAAO,IAAIO,GAAoB,SAAU1B,GACvC,GAAI4E,MACApE,EAAwB,GAAIU,GAC5B4E,EAAcjE,EAChB,SAAUkE,GAAK/F,EAAEM,OAAOyF,IACxB,SAAUC,GACRxF,EAAsByC,QAAQ,SAAUgB,GAAKA,EAAEhE,QAAQ+F,KACvDhG,EAAEC,QAAQ+F,IAEZ,SAAUD,GAAK/F,EAAEgB,eAEnB,KACE,IAAK,GAAIG,GAAI,EAAGC,EAAMuE,EAAMtE,OAAYD,EAAJD,EAASA,IAC3CyD,EAAY5B,KAAK2C,EAAMxE,GAAGqC,SAAShD,EAAuBsF,EAAa,SAAUnC,GAC/E,GAAIsC,GAAMrB,EAAY9B,QAAQa,EAC9BiB,GAAY7B,OAAOkD,EAAK,GACD,IAAvBrB,EAAYvD,QAAgBrB,EAAEgB,iBAGlC,MAAOxB,GACPmC,EAAgBnC,GAAG6F,UAAUrF,GAE/B,GAAIkG,GAAQ,GAAIjE,EAMhB,OALAzB,GAAsByC,QAAQ,SAAU3B,GACtCA,EAAa+D,YACba,EAAMC,IAAI7E,KAGL4E,KAIJnH"} |