{"version":3,"file":"rx.experimental.min.js","sources":["rx.experimental.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","enumerableWhile","condition","source","Enumerable","Enumerator","done","value","Observable","observableProto","prototype","AnonymousObservable","observableConcat","concat","observableDefer","defer","observableEmpty","empty","disposableEmpty","Disposable","CompositeDisposable","SerialDisposable","SingleAssignmentDisposable","internals","enumerableOf","of","immediateScheduler","Scheduler","immediate","currentThreadScheduler","currentThread","AsyncSubject","Observer","inherits","addProperties","helpers","noop","isPromise","isScheduler","observableFromPromise","fromPromise","$iterator$","Symbol","iterator","Set","doneEnumerator","isIterable","o","isArrayLike","letBind","func","ifThen","thenSource","elseSourceOrScheduler","now","forIn","sources","resultSelector","thisArg","observableWhileDo","whileDo","doWhile","switchCase","selector","defaultSourceOrScheduler","result","expand","scheduler","observer","q","m","d","activeCount","isAcquired","ensureActive","isOwner","setDisposable","scheduleRecursive","self","work","shift","m1","add","subscribe","x","onNext","e","onError","push","bind","remove","onCompleted","forkJoin","allSources","arguments","subscriber","count","group","finished","hasResults","hasCompleted","results","i","dispose","ix","second","first","lastLeft","lastRight","leftStopped","rightStopped","hasLeft","hasRight","leftSubscription","rightSubscription","left","err","right","manySelect","chain","map","curr","ChainObservable","tap","observeOn","__super__","g","schedule","head","tail","mergeAll","throwException","v","exclusive","hasCurrent","isStopped","innerSource","innerSubscription","exclusiveMap","index"],"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,GA8BpC,QAASiB,GAAYC,EAAMC,GACzB,MAAuB,KAAhBD,EAAKE,QAAgBC,MAAMC,QAAQJ,EAAKC,IAC7CD,EAAKC,GACLI,EAAMR,KAAKG,GAuBf,QAASM,GAAgBC,EAAWC,GAClC,MAAO,IAAIC,GAAW,WACpB,MAAO,IAAIC,GAAW,WACpB,MAAOH,MACHI,MAAM,EAAOC,MAAOJ,IACpBG,MAAM,EAAMC,MAAO9B,OA1D7B,GAAI+B,GAAalB,EAAGkB,WAClBC,EAAkBD,EAAWE,UAC7BC,EAAsBrB,EAAGqB,oBACzBC,EAAmBJ,EAAWK,OAC9BC,EAAkBN,EAAWO,MAC7BC,EAAkBR,EAAWS,MAC7BC,EAAkB5B,EAAG6B,WAAWF,MAChCG,EAAsB9B,EAAG8B,oBACzBC,EAAmB/B,EAAG+B,iBACtBC,EAA6BhC,EAAGgC,2BAChCjB,EAAaf,EAAGiC,UAAUlB,WAC1BD,EAAad,EAAGiC,UAAUnB,WAC1BoB,EAAepB,EAAWqB,GAC1BC,EAAqBpC,EAAGqC,UAAUC,UAClCC,EAAyBvC,EAAGqC,UAAUG,cACtC9B,EAAQF,MAAMY,UAAUV,MACxB+B,EAAezC,EAAGyC,aAClBC,EAAW1C,EAAG0C,SACdC,EAAW3C,EAAGiC,UAAUU,SACxBC,EAAgB5C,EAAGiC,UAAUW,cAC7BC,EAAU7C,EAAG6C,QACbC,EAAOD,EAAQC,KACfC,EAAYF,EAAQE,UACpBC,EAAcH,EAAQG,YACtBC,EAAwB/B,EAAWgC,YAUjCC,EAAgC,kBAAXC,SAAyBA,OAAOC,UACvD,oBAEEjE,GAAKkE,KAA+C,mBAAjC,GAAIlE,GAAKkE,KAAM,gBACpCH,EAAa,aAGMnD,GAAGuD,gBAAmBvC,MAAM,EAAMC,MAAO9B,GAE7Ca,EAAG6C,QAAQW,WAAa,SAAUC,GACjD,MAAOA,GAAEN,KAAgBhE,GAGTa,EAAG6C,QAAQa,YAAc,SAAUD,GACnD,MAAOA,IAAKA,EAAElD,SAAWpB,EAG3Ba,GAAG6C,QAAQQ,SAAWF,EAmBtBhC,EAAgBwC,QAAUxC,EAAqB,IAAI,SAAUyC,GAC3D,MAAOA,GAAKtE,OAed4B,EAAW,MAAQA,EAAW2C,OAAS,SAAUjD,EAAWkD,EAAYC,GACtE,MAAOvC,GAAgB,WAQrB,MAPAuC,KAA0BA,EAAwBrC,KAElDqB,EAAUe,KAAgBA,EAAab,EAAsBa,IAC7Df,EAAUgB,KAA2BA,EAAwBd,EAAsBc,IAG9C,kBAA9BA,GAAsBC,MAAuBD,EAAwBrC,EAAgBqC,IACrFnD,IAAckD,EAAaC,KAWtC7C,EAAW,OAASA,EAAW+C,MAAQ,SAAUC,EAASC,EAAgBC,GACxE,MAAOlC,GAAagC,EAASC,EAAgBC,GAAS7C,SAWxD,IAAI8C,GAAoBnD,EAAW,SAAWA,EAAWoD,QAAU,SAAU1D,EAAWC,GAEtF,MADAkC,GAAUlC,KAAYA,EAASoC,EAAsBpC,IAC9CF,EAAgBC,EAAWC,GAAQU,SAU5CJ,GAAgBoD,QAAU,SAAU3D,GAClC,MAAOU,IAAkBhC,KAAM+E,EAAkBzD,EAAWtB,SAkB9D4B,EAAW,QAAUA,EAAWsD,WAAa,SAAUC,EAAUP,EAASQ,GACxE,MAAOlD,GAAgB,WACrBuB,EAAU2B,KAA8BA,EAA2BzB,EAAsByB,IACzFA,IAA6BA,EAA2BhD,KAEhB,kBAAjCgD,GAAyBV,MAAuBU,EAA2BhD,EAAgBgD,GAElG,IAAIC,GAAST,EAAQO,IAGrB,OAFA1B,GAAU4B,KAAYA,EAAS1B,EAAsB0B,IAE9CA,GAAUD,KAWrBvD,EAAgByD,OAAS,SAAUH,EAAUI,GAC3C7B,EAAY6B,KAAeA,EAAYzC,EACvC,IAAIvB,GAASvB,IACb,OAAO,IAAI+B,GAAoB,SAAUyD,GACvC,GAAIC,MACFC,EAAI,GAAIjD,GACRkD,EAAI,GAAInD,GAAoBkD,GAC5BE,EAAc,EACdC,GAAa,EAEXC,EAAe,WACjB,GAAIC,IAAU,CACVN,GAAExE,OAAS,IACb8E,GAAWF,EACXA,GAAa,GAEXE,GACFL,EAAEM,cAAcT,EAAUU,kBAAkB,SAAUC,GACpD,GAAIC,EACJ,MAAIV,EAAExE,OAAS,GAIb,YADA4E,GAAa,EAFbM,GAAOV,EAAEW,OAKX,IAAIC,GAAK,GAAI3D,EACbiD,GAAEW,IAAID,GACNA,EAAGL,cAAcG,EAAKI,UAAU,SAAUC,GACxChB,EAASiB,OAAOD,EAChB,IAAInB,GAAS,IACb,KACEA,EAASF,EAASqB,GAClB,MAAOE,GACPlB,EAASmB,QAAQD,GAEnBjB,EAAEmB,KAAKvB,GACPO,IACAE,KACCN,EAASmB,QAAQE,KAAKrB,GAAW,WAClCG,EAAEmB,OAAOT,GACTT,IACoB,IAAhBA,GACFJ,EAASuB,iBAGbb,OAQN,OAHAT,GAAEmB,KAAKrF,GACPqE,IACAE,IACOH,GACN3F,OAWL4B,EAAWoF,SAAW,WACpB,GAAIC,GAAanG,EAAYoG,UAAW,EACxC,OAAO,IAAInF,GAAoB,SAAUoF,GACvC,GAAIC,GAAQH,EAAWhG,MACvB,IAAc,IAAVmG,EAEF,MADAD,GAAWJ,cACJzE,CAQT,KAAK,GAND+E,GAAQ,GAAI7E,GACd8E,GAAW,EACXC,EAAa,GAAIrG,OAAMkG,GACvBI,EAAe,GAAItG,OAAMkG,GACzBK,EAAU,GAAIvG,OAAMkG,GAEbpG,EAAM,EAASoG,EAANpG,EAAaA,KAC7B,SAAW0G,GACT,GAAInG,GAAS0F,EAAWS,EACxBjE,GAAUlC,KAAYA,EAASoC,EAAsBpC,IACrD8F,EAAMf,IACJ/E,EAAOgF,UACL,SAAU5E,GACL2F,IACHC,EAAWG,IAAK,EAChBD,EAAQC,GAAK/F,IAGjB,SAAU+E,GACRY,GAAW,EACXH,EAAWR,QAAQD,GACnBW,EAAMM,WAER,WACE,IAAKL,EAAU,CACb,IAAKC,EAAWG,GAEZ,WADAP,GAAWJ,aAGfS,GAAaE,IAAK,CAClB,KAAK,GAAIE,GAAK,EAAQR,EAALQ,EAAYA,IAC3B,IAAKJ,EAAaI,GAAO,MAE3BN,IAAW,EACXH,EAAWV,OAAOgB,GAClBN,EAAWJ,mBAGhB/F,EAGL,OAAOqG,MAWXxF,EAAgBmF,SAAW,SAAUa,EAAQhD,GAC3C,GAAIiD,GAAQ9H,IAEZ,OAAO,IAAI+B,GAAoB,SAAUyD,GACvC,GAEEuC,GAAUC,EAFRC,GAAc,EAAOC,GAAe,EACtCC,GAAU,EAAOC,GAAW,EAE5BC,EAAmB,GAAI3F,GAA8B4F,EAAoB,GAAI5F,EA8D/E,OA5DAe,GAAUoE,KAAYA,EAASlE,EAAsBkE,IAErDQ,EAAiBrC,cACb8B,EAAMvB,UAAU,SAAUgC,GACxBJ,GAAU,EACVJ,EAAWQ,GACV,SAAUC,GACXF,EAAkBX,UAClBnC,EAASmB,QAAQ6B,IAChB,WAED,GADAP,GAAc,EACVC,EACF,GAAKC,EAEE,GAAKC,EAEL,CACL,GAAI/C,EACJ,KACEA,EAASR,EAAekD,EAAUC,GAClC,MAAOtB,GAEP,WADAlB,GAASmB,QAAQD,GAGnBlB,EAASiB,OAAOpB,GAChBG,EAASuB,kBAVPvB,GAASuB,kBAFTvB,GAASuB,iBAkBrBuB,EAAkBtC,cAChB6B,EAAOtB,UAAU,SAAUkC,GACzBL,GAAW,EACXJ,EAAYS,GACX,SAAUD,GACXH,EAAiBV,UACjBnC,EAASmB,QAAQ6B,IAChB,WAED,GADAN,GAAe,EACXD,EACF,GAAKE,EAEE,GAAKC,EAEL,CACL,GAAI/C,EACJ,KACEA,EAASR,EAAekD,EAAUC,GAClC,MAAOtB,GAEP,WADAlB,GAASmB,QAAQD,GAGnBlB,EAASiB,OAAOpB,GAChBG,EAASuB,kBAVTvB,GAASuB,kBAFTvB,GAASuB,iBAkBV,GAAIvE,GAAoB6F,EAAkBC,IAChDR,IASLjG,EAAgB6G,WAAa,SAAUvD,EAAUI,GAC/C7B,EAAY6B,KAAeA,EAAYzC,EACvC,IAAIvB,GAASvB,IACb,OAAOkC,GAAgB,WACrB,GAAIyG,EAEJ,OAAOpH,GACJqH,IAAI,SAAUpC,GACb,GAAIqC,GAAO,GAAIC,GAAgBtC,EAK/B,OAHAmC,IAASA,EAAMlC,OAAOD,GACtBmC,EAAQE,EAEDA,IAERE,IACCvF,EACA,SAAUkD,GAAKiC,GAASA,EAAMhC,QAAQD,IACtC,WAAciC,GAASA,EAAM5B,gBAE9BiC,UAAUzD,GACVqD,IAAIzD,IACN5D,GAGL,IAAIuH,GAAmB,SAAUG,GAE/B,QAAS1C,GAAWf,GAClB,GAAIU,GAAOlG,KAAMkJ,EAAI,GAAI1G,EAMzB,OALA0G,GAAE5C,IAAIrD,EAAuBkG,SAAS,WACpC3D,EAASiB,OAAOP,EAAKkD,MACrBF,EAAE5C,IAAIJ,EAAKmD,KAAKC,WAAW/C,UAAUf,OAGhC0D,EAKT,QAASJ,GAAgBM,GACvBH,EAAUrI,KAAKZ,KAAMuG,GACrBvG,KAAKoJ,KAAOA,EACZpJ,KAAKqJ,KAAO,GAAIlG,GAgBlB,MArBAE,GAASyF,EAAiBG,GAQ1B3F,EAAcwF,EAAgBhH,UAAWsB,GACvC2D,YAAa,WACX/G,KAAKyG,OAAO7E,EAAWS,UAEzBsE,QAAS,SAAUD,GACjB1G,KAAKyG,OAAO7E,EAAW2H,eAAe7C,KAExCD,OAAQ,SAAU+C,GAChBxJ,KAAKqJ,KAAK5C,OAAO+C,GACjBxJ,KAAKqJ,KAAKtC,iBAIP+B,GAEPlH,EAkHA,OA3GFC,GAAgB4H,UAAY,WAC1B,GAAI7E,GAAU5E,IACd,OAAO,IAAI+B,GAAoB,SAAUyD,GACvC,GAAIkE,IAAa,EACfC,GAAY,EACZjE,EAAI,GAAIhD,GACRwG,EAAI,GAAI1G,EAkCV,OAhCA0G,GAAE5C,IAAIZ,GAENA,EAAEM,cAAcpB,EAAQ2B,UACtB,SAAUqD,GACR,IAAKF,EAAY,CACfA,GAAa,EAEbjG,EAAUmG,KAAiBA,EAAcjG,EAAsBiG,GAE/D,IAAIC,GAAoB,GAAInH,EAC5BwG,GAAE5C,IAAIuD,GAENA,EAAkB7D,cAAc4D,EAAYrD,UAC1Cf,EAASiB,OAAOI,KAAKrB,GACrBA,EAASmB,QAAQE,KAAKrB,GACtB,WACE0D,EAAEpC,OAAO+C,GACTH,GAAa,EACTC,GAA0B,IAAbT,EAAEjI,QACjBuE,EAASuB,mBAKnBvB,EAASmB,QAAQE,KAAKrB,GACtB,WACEmE,GAAY,EACPD,GAA2B,IAAbR,EAAEjI,QACnBuE,EAASuB,iBAIRmC,GACNlJ,OAUL6B,EAAgBiI,aAAe,SAAU3E,EAAUL,GACjD,GAAIF,GAAU5E,IACd,OAAO,IAAI+B,GAAoB,SAAUyD,GACvC,GAAIuE,GAAQ,EACVL,GAAa,EACbC,GAAY,EACZjE,EAAI,GAAIhD,GACRwG,EAAI,GAAI1G,EA6CV,OA3CA0G,GAAE5C,IAAIZ,GAENA,EAAEM,cAAcpB,EAAQ2B,UACtB,SAAUqD,GAEHF,IACHA,GAAa,EAEbG,kBAAoB,GAAInH,GACxBwG,EAAE5C,IAAIuD,mBAENpG,EAAUmG,KAAiBA,EAAcjG,EAAsBiG,IAE/DC,kBAAkB7D,cAAc4D,EAAYrD,UAC1C,SAAUC,GACR,GAAInB,EACJ,KACEA,EAASF,EAASvE,KAAKkE,EAAS0B,EAAGuD,IAASH,GAC5C,MAAOlD,GAEP,WADAlB,GAASmB,QAAQD,GAInBlB,EAASiB,OAAOpB,IAElBG,EAASmB,QAAQE,KAAKrB,GACtB,WACE0D,EAAEpC,OAAO+C,mBACTH,GAAa,EAETC,GAA0B,IAAbT,EAAEjI,QACjBuE,EAASuB,mBAKnBvB,EAASmB,QAAQE,KAAKrB,GACtB,WACEmE,GAAY,EACK,IAAbT,EAAEjI,QAAiByI,GACrBlE,EAASuB,iBAGRmC,GACNlJ,OAGIU"}