| 1 |
- {"version":3,"file":"rx.experimental.min.js","sources":["rx.experimental.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","enumerableWhile","condition","source","WhileEnumerable","argumentsToArray","len","length","args","Array","i","Observable","observableProto","prototype","ObservableBase","AbstractObserver","internals","FlatMapObservable","observableConcat","concat","observableDefer","defer","observableEmpty","empty","disposableEmpty","Disposable","CompositeDisposable","SerialDisposable","SingleAssignmentDisposable","Enumerable","enumerableOf","of","currentThreadScheduler","Scheduler","currentThread","AsyncSubject","Observer","inherits","addProperties","helpers","noop","isPromise","isFunction","isScheduler","isIterable","isArrayLike","observableFromPromise","fromPromise","tryCatch","fn","TypeError","$iterator$","Symbol","iterator","Set","doneEnumerator","done","o","__super__","c","s","next","letBind","func","thenSource","elseSourceOrScheduler","now","forIn","sources","resultSelector","thisArg","observableWhileDo","whileDo","doWhile","selector","defaultSourceOrScheduler","result","ExpandObservable","scheduler","_fn","_scheduler","scheduleRecursive","recurse","work","state","q","isAcquired","shift","m1","d","add","setDisposable","subscribe","ExpandObserver","_ensureActive","isOwner","m","subscribeCore","activeCount","push","parent","_s","_p","_m1","x","onNext","onError","error","completed","remove","onCompleted","expand","ForkJoinObservable","cb","_sources","_cb","count","finished","hasResults","hasCompleted","results","subscriptions","ForkJoinObserver","subs","_o","_i","_subs","dispose","res","forkJoin","pop","isArray","unshift","manySelect","extend","immediate","chain","map","curr","ChainObservable","tap","observeOn","head","tail","_subscribe","g","schedule","_","mergeAll","v","SwitchFirstObservable","hasCurrent","isStopped","SwitchFirstObserver","InnerObserver","inner","switchFirst","flatMapFirst","exhaustMap","flatMapWithMaxConcurrent","flatMapMaxConcurrent","limit","merge"],"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,GAiCpC,QAASC,GAAcC,GACrB,MAAO,YACL,IACE,MAAOA,GAAeC,MAAMZ,KAAMa,WAClC,MAAOC,GAEP,MADAC,GAASD,EAAIA,EACNC,IAqDb,QAASC,GAAgBC,EAAWC,GAClC,MAAO,IAAIC,GAAgBF,EAAWC,GAiMxC,QAASE,KAEP,IAAI,GADAC,GAAMR,UAAUS,OAAQC,EAAO,GAAIC,OAAMH,GACrCI,EAAI,EAAOJ,EAAJI,EAASA,IAAOF,EAAKE,GAAKZ,UAAUY,EACnD,OAAOF,GA9RT,GAAIG,GAAarB,EAAGqB,WAClBC,EAAkBD,EAAWE,UAC7BC,EAAiBxB,EAAGwB,eACpBC,EAAmBzB,EAAG0B,UAAUD,iBAChCE,EAAoB3B,EAAG2B,kBACvBC,EAAmBP,EAAWQ,OAC9BC,EAAkBT,EAAWU,MAC7BC,EAAkBX,EAAWY,MAC7BC,EAAkBlC,EAAGmC,WAAWF,MAChCG,EAAsBpC,EAAGoC,oBACzBC,EAAmBrC,EAAGqC,iBACtBC,EAA6BtC,EAAGsC,2BAChCC,EAAavC,EAAG0B,UAAUa,WAC1BC,EAAeD,EAAWE,GAC1BC,EAAyB1C,EAAG2C,UAAUC,cACtCC,EAAe7C,EAAG6C,aAClBC,EAAW9C,EAAG8C,SACdC,EAAW/C,EAAG0B,UAAUqB,SACxBC,EAAgBhD,EAAG0B,UAAUsB,cAC7BC,EAAUjD,EAAGiD,QACbC,EAAOD,EAAQC,KACfC,EAAYF,EAAQE,UACpBC,EAAaH,EAAQG,WAGrBC,GAFarD,EAAGiD,QAAQK,WACVtD,EAAGiD,QAAQM,YACXvD,EAAG2C,UAAUU,aAC3BG,EAAwBnC,EAAWoC,YAEjC/C,GAAYD,MAaZiD,EAAW1D,EAAG0B,UAAUgC,SAAW,SAAkBC,GACvD,IAAKP,EAAWO,GAAO,KAAM,IAAIC,WAAU,wBAC3C,OAAOvD,GAAcsD,IAQnBE,EAAgC,kBAAXC,SAAyBA,OAAOC,UACvD,oBAEEnE,GAAKoE,KAA+C,mBAAjC,GAAIpE,GAAKoE,KAAM,gBACpCH,EAAa,aAGM7D,GAAGiE,gBAAmBC,MAAM,EAAMxF,MAAO0B,GAE7CJ,EAAGiD,QAAQK,WAAa,SAAUa,GACjD,MAAOA,IAAKA,EAAEN,KAAgBzD,GAGdJ,EAAGiD,QAAQM,YAAc,SAAUY,GACnD,MAAOA,IAAKA,EAAElD,SAAWb,EAG3BJ,GAAGiD,QAAQc,SAAWF,CAEtB,IAAI/C,GAAmB,SAASsD,GAE9B,QAAStD,GAAgBuD,EAAGC,GAC1B3E,KAAK0E,EAAIA,EACT1E,KAAK2E,EAAIA,EAYX,MAfAvB,GAASjC,EAAiBsD,GAK1BtD,EAAgBS,UAAUsC,GAAc,WACtC,GAAItE,GAAOI,IACX,QACE4E,KAAM,WACJ,MAAOhF,GAAK8E,KACTH,MAAM,EAAOxF,MAAOa,EAAK+E,IACzBJ,MAAM,EAAMxF,MAAO,WAIrBoC,GACPyB,EAaFjB,GAAgBkD,QAAUlD,EAAqB,IAAI,SAAUmD,GAC3D,MAAOA,GAAK9E,OAed0B,EAAW,MAAQ,SAAUT,EAAW8D,EAAYC,GAClD,MAAO7C,GAAgB,WAQrB,MAPA6C,KAA0BA,EAAwB3C,KAElDmB,EAAUuB,KAAgBA,EAAalB,EAAsBkB,IAC7DvB,EAAUwB,KAA2BA,EAAwBnB,EAAsBmB,IAG9C,kBAA9BA,GAAsBC,MAAuBD,EAAwB3C,EAAgB2C,IACrF/D,IAAc8D,EAAaC,KAWtCtD,EAAW,OAASA,EAAWwD,MAAQ,SAAUC,EAASC,EAAgBC,GACxE,MAAOxC,GAAasC,EAASC,EAAgBC,GAASnD,SAWxD,IAAIoD,GAAoB5D,EAAW,SAAWA,EAAW6D,QAAU,SAAUtE,EAAWC,GAEtF,MADAsC,GAAUtC,KAAYA,EAAS2C,EAAsB3C,IAC9CF,EAAgBC,EAAWC,GAAQgB,SAU5CP,GAAgB6D,QAAU,SAAUvE,GAClC,MAAOgB,IAAkBjC,KAAMsF,EAAkBrE,EAAWjB,SAW9D0B,EAAW,QAAU,SAAU+D,EAAUN,EAASO,GAChD,MAAOvD,GAAgB,WACrBqB,EAAUkC,KAA8BA,EAA2B7B,EAAsB6B,IACzFA,IAA6BA,EAA2BrD,KAExDqB,EAAYgC,KAA8BA,EAA2BrD,EAAgBqD,GAErF,IAAIC,GAASR,EAAQM,IAGrB,OAFAjC,GAAUmC,KAAYA,EAAS9B,EAAsB8B,IAE9CA,GAAUD,IAIrB,IAAIE,GAAoB,SAASnB,GAE/B,QAASmB,GAAiB1E,EAAQ8C,EAAI6B,GACpC7F,KAAKkB,OAASA,EACdlB,KAAK8F,IAAM9B,EACXhE,KAAK+F,WAAaF,EAClBpB,EAAUlE,KAAKP,MAGjB,QAASgG,GAAkBzE,EAAM0E,GAC/B,GACIC,GADAC,EAAQ5E,EAAK,GAAI3B,EAAO2B,EAAK,EAEjC,MAAI4E,EAAMC,EAAE9E,OAAS,GAInB,YADA6E,EAAME,YAAa,EAFnBH,GAAOC,EAAMC,EAAEE,OAKjB,IAAIC,GAAK,GAAI5D,EACbwD,GAAMK,EAAEC,IAAIF,GACZA,EAAGG,cAAcR,EAAKS,UAAU,GAAIC,GAAeT,EAAOvG,EAAM2G,KAChEN,GAASE,EAAOvG,IA8BlB,MAlDAwD,GAASwC,EAAkBnB,GAuB3BmB,EAAiBhE,UAAUiF,cAAgB,SAAUV,GACnD,GAAIW,IAAU,CACVX,GAAMC,EAAE9E,OAAS,IACnBwF,GAAWX,EAAME,WACjBF,EAAME,YAAa,GAErBS,GAAWX,EAAMY,EAAEL,cAAc1G,KAAK+F,WAAWC,mBAAmBG,EAAOnG,MAAOgG,KAGpFJ,EAAiBhE,UAAUoF,cAAgB,SAAUxC,GACnD,GAAIuC,GAAI,GAAIrE,GACV8D,EAAI,GAAI/D,GAAoBsE,GAC5BZ,GACEC,KACAW,EAAGA,EACHP,EAAGA,EACHS,YAAa,EACbZ,YAAY,EACZ7B,EAAGA,EAMP,OAHA2B,GAAMC,EAAEc,KAAKlH,KAAKkB,QAClBiF,EAAMc,cACNjH,KAAK6G,cAAcV,GACZK,GAGFZ,GACP/D,GAEE+E,EAAkB,SAASnC,GAE7B,QAASmC,GAAeT,EAAOgB,EAAQZ,GACrCvG,KAAKoH,GAAKjB,EACVnG,KAAKqH,GAAKF,EACVnH,KAAKsH,IAAMf,EACX9B,EAAUlE,KAAKP,MAsBjB,MA3BAoD,GAASwD,EAAgBnC,GAQzBmC,EAAehF,UAAUgD,KAAO,SAAU2C,GACxCvH,KAAKoH,GAAG5C,EAAEgD,OAAOD,EACjB,IAAI5B,GAAS5B,EAAS/D,KAAKqH,GAAGvB,KAAKyB,EACnC,OAAI5B,KAAW5E,EAAmBf,KAAKoH,GAAG5C,EAAEiD,QAAQ9B,EAAO7E,IAC3Dd,KAAKoH,GAAGhB,EAAEc,KAAKvB,GACf3F,KAAKoH,GAAGH,kBACRjH,MAAKqH,GAAGR,cAAc7G,KAAKoH,MAG7BR,EAAehF,UAAU8F,MAAQ,SAAU5G,GACzCd,KAAKoH,GAAG5C,EAAEiD,QAAQ3G,IAGpB8F,EAAehF,UAAU+F,UAAY,WACnC3H,KAAKoH,GAAGZ,EAAEoB,OAAO5H,KAAKsH,KACtBtH,KAAKoH,GAAGH,cACgB,IAAxBjH,KAAKoH,GAAGH,aAAqBjH,KAAKoH,GAAG5C,EAAEqD,eAGlCjB,GACP9E,EASFH,GAAgBmG,OAAS,SAAUrC,EAAUI,GAE3C,MADAnC,GAAYmC,KAAeA,EAAY9C,GAChC,GAAI6C,GAAiB5F,KAAMyF,EAAUI,GAS9C,IAAIkC,GAAsB,SAAUtD,GAElC,QAASsD,GAAmB5C,EAAS6C,GACnChI,KAAKiI,SAAW9C,EAChBnF,KAAKkI,IAAMF,EACXvD,EAAUlE,KAAKP,MA2BjB,MA/BAoD,GAAS2E,EAAoBtD,GAO7BsD,EAAmBnG,UAAUoF,cAAgB,SAAUxC,GACrD,GAA6B,IAAzBxE,KAAKiI,SAAS3G,OAEhB,MADAkD,GAAEqD,cACKtF,CAYT,KAAK,GATD4F,GAAQnI,KAAKiI,SAAS3G,OACtB6E,GACFiC,UAAU,EACVC,WAAY,GAAI7G,OAAM2G,GACtBG,aAAc,GAAI9G,OAAM2G,GACxBI,QAAS,GAAI/G,OAAM2G,IAGjBK,EAAgB,GAAI/F,GACfhB,EAAI,EAAGJ,EAAMrB,KAAKiI,SAAS3G,OAAYD,EAAJI,EAASA,IAAK,CACxD,GAAIP,GAASlB,KAAKiI,SAASxG,EAC3B+B,GAAUtC,KAAYA,EAAS2C,EAAsB3C,IACrDsH,EAAc/B,IAAIvF,EAAOyF,UAAU,GAAI8B,GAAiBjE,EAAG2B,EAAO1E,EAAGzB,KAAKkI,IAAKM,KAGjF,MAAOA,IAGFT,GACPlG,GAEE4G,EAAoB,SAAShE,GAE/B,QAASgE,GAAiBjE,EAAGG,EAAGlD,EAAGuG,EAAIU,GACrC1I,KAAK2I,GAAKnE,EACVxE,KAAKoH,GAAKzC,EACV3E,KAAK4I,GAAKnH,EACVzB,KAAKkI,IAAMF,EACXhI,KAAK6I,MAAQH,EACbjE,EAAUlE,KAAKP,MAmCjB,MA1CAoD,GAASqF,EAAkBhE,GAU3BgE,EAAiB7G,UAAUgD,KAAO,SAAU2C,GACrCvH,KAAKoH,GAAGgB,WACXpI,KAAKoH,GAAGiB,WAAWrI,KAAK4I,KAAM,EAC9B5I,KAAKoH,GAAGmB,QAAQvI,KAAK4I,IAAMrB,IAI/BkB,EAAiB7G,UAAU8F,MAAQ,SAAU5G,GAC3Cd,KAAKoH,GAAGgB,UAAW,EACnBpI,KAAK2I,GAAGlB,QAAQ3G,GAChBd,KAAK6I,MAAMC,WAGbL,EAAiB7G,UAAU+F,UAAY,WACrC,IAAK3H,KAAKoH,GAAGgB,SAAU,CACrB,IAAKpI,KAAKoH,GAAGiB,WAAWrI,KAAK4I,IAC3B,MAAO5I,MAAK2I,GAAGd,aAEjB7H,MAAKoH,GAAGkB,aAAatI,KAAK4I,KAAM,CAChC,KAAK,GAAInH,GAAI,EAAGA,EAAIzB,KAAKoH,GAAGmB,QAAQjH,OAAQG,IAC1C,IAAKzB,KAAKoH,GAAGkB,aAAa7G,GAAM,MAElCzB,MAAKoH,GAAGgB,UAAW,CAEnB,IAAIW,GAAMhF,EAAS/D,KAAKkI,KAAKtH,MAAM,KAAMZ,KAAKoH,GAAGmB,QACjD,IAAIQ,IAAQhI,EAAY,MAAOf,MAAK2I,GAAGlB,QAAQsB,EAAIjI,EAEnDd,MAAK2I,GAAGnB,OAAOuB,GACf/I,KAAK2I,GAAGd,gBAILY,GACP3G,EAUFJ,GAAWsH,SAAW,WAEpB,IAAI,GADA3H,GAAMR,UAAUS,OAAQC,EAAO,GAAIC,OAAMH,GACrCI,EAAI,EAAOJ,EAAJI,EAASA,IAAOF,EAAKE,GAAKZ,UAAUY,EACnD,IAAI2D,GAAiB3B,EAAWlC,EAAKF,EAAM,IAAME,EAAK0H,MAAQ7H,CAE9D,OADAI,OAAM0H,QAAQ3H,EAAK,MAAQA,EAAOA,EAAK,IAChC,GAAIwG,GAAmBxG,EAAM6D,IAStCzD,EAAgBqH,SAAW,WAEzB,IAAI,GADA3H,GAAMR,UAAUS,OAAQC,EAAO,GAAIC,OAAMH,GACrCI,EAAI,EAAOJ,EAAJI,EAASA,IAAOF,EAAKE,GAAKZ,UAAUY,EAMnD,OALID,OAAM0H,QAAQ3H,EAAK,IACrBA,EAAK,GAAG4H,QAAQnJ,MAEhBuB,EAAK4H,QAAQnJ,MAER0B,EAAWsH,SAASpI,MAAM,KAAMW,IASzCI,EAAgByH,WAAazH,EAAgB0H,OAAS,SAAU5D,EAAUI,GACxEnC,EAAYmC,KAAeA,EAAYxF,EAAG2C,UAAUsG,UACpD,IAAIpI,GAASlB,IACb,OAAOmC,GAAgB,WACrB,GAAIoH,EAEJ,OAAOrI,GACJsI,IAAI,SAAUjC,GACb,GAAIkC,GAAO,GAAIC,GAAgBnC,EAK/B,OAHAgC,IAASA,EAAM/B,OAAOD,GACtBgC,EAAQE,EAEDA,IAERE,IACCpG,EACA,SAAUzC,GAAKyI,GAASA,EAAM9B,QAAQ3G,IACtC,WAAcyI,GAASA,EAAM1B,gBAE9B+B,UAAU/D,GACV2D,IAAI/D,IACNvE,GAGL,IAAIwI,GAAmB,SAAUjF,GAE/B,QAASiF,GAAgBG,GACvBpF,EAAUlE,KAAKP,MACfA,KAAK6J,KAAOA,EACZ7J,KAAK8J,KAAO,GAAI5G,GAyBlB,MA7BAE,GAASsG,EAAiBjF,GAO1BpB,EAAcqG,EAAgB9H,UAAWuB,GACvC4G,WAAY,SAAUvF,GACpB,GAAIwF,GAAI,GAAIvH,EAMZ,OALAuH,GAAEvD,IAAI1D,EAAuBkH,SAASjK,KAAM,SAAUkK,EAAGtK,GACvD4E,EAAEgD,OAAO5H,EAAKiK,MACdG,EAAEvD,IAAI7G,EAAKkK,KAAKK,WAAWxD,UAAUnC,OAGhCwF,GAETnC,YAAa,WACX7H,KAAKwH,OAAO9F,EAAWY,UAEzBmF,QAAS,SAAU3G,GACjBd,KAAKwH,OAAO9F,EAAW,SAASZ,KAElC0G,OAAQ,SAAU4C,GAChBpK,KAAK8J,KAAKtC,OAAO4C,GACjBpK,KAAK8J,KAAKjC,iBAIP6B,GAEPhI,GAEE2I,EAAyB,SAAU5F,GAErC,QAAS4F,GAAsBnJ,GAC7BlB,KAAKkB,OAASA,EACduD,EAAUlE,KAAKP,MAkBjB,MArBAoD,GAASiH,EAAuB5F,GAMhC4F,EAAsBzI,UAAUoF,cAAgB,SAAUxC,GACxD,GAAIuC,GAAI,GAAIpE,GACVqH,EAAI,GAAIvH,GACR0D,GACEmE,YAAY,EACZC,WAAW,EACX/F,EAAGA,EACHwF,EAAGA,EAKP,OAFAA,GAAEvD,IAAIM,GACNA,EAAEL,cAAc1G,KAAKkB,OAAOyF,UAAU,GAAI6D,GAAoBrE,KACvD6D,GAGFK,GACPxI,GAEE2I,EAAuB,SAAS/F,GAElC,QAAS+F,GAAoBrE,GAC3BnG,KAAKoH,GAAKjB,EACV1B,EAAUlE,KAAKP,MAuBjB,QAASyK,GAActE,EAAOuE,GAC5B1K,KAAKoH,GAAKjB,EACVnG,KAAK4I,GAAK8B,EACVjG,EAAUlE,KAAKP,MAWjB,MAxCAoD,GAASoH,EAAqB/F,GAM9B+F,EAAoB5I,UAAUgD,KAAO,SAAU2C,GAC7C,IAAKvH,KAAKoH,GAAGkD,WAAY,CACvBtK,KAAKoH,GAAGkD,YAAa,EACrB9G,EAAU+D,KAAOA,EAAI1D,EAAsB0D,GAC3C,IAAImD,GAAQ,GAAI/H,EAChB3C,MAAKoH,GAAG4C,EAAEvD,IAAIiE,GACdA,EAAMhE,cAAca,EAAEZ,UAAU,GAAI8D,GAAczK,KAAKoH,GAAIsD,OAI/DF,EAAoB5I,UAAU8F,MAAQ,SAAU5G,GAC9Cd,KAAKoH,GAAG5C,EAAEiD,QAAQ3G,IAGpB0J,EAAoB5I,UAAU+F,UAAY,WACxC3H,KAAKoH,GAAGmD,WAAY,GACnBvK,KAAKoH,GAAGkD,YAAmC,IAArBtK,KAAKoH,GAAG4C,EAAE1I,QAAgBtB,KAAKoH,GAAG5C,EAAEqD,eAG7DzE,EAASqH,EAAehG,GAOxBgG,EAAc7I,UAAUgD,KAAO,SAAU2C,GAAKvH,KAAKoH,GAAG5C,EAAEgD,OAAOD,IAC/DkD,EAAc7I,UAAU8F,MAAQ,SAAU5G,GAAKd,KAAKoH,GAAG5C,EAAEiD,QAAQ3G,IACjE2J,EAAc7I,UAAU+F,UAAY,WAClC3H,KAAKoH,GAAG4C,EAAEpC,OAAO5H,KAAK4I,IACtB5I,KAAKoH,GAAGkD,YAAa,EACrBtK,KAAKoH,GAAGmD,WAAkC,IAArBvK,KAAKoH,GAAG4C,EAAE1I,QAAgBtB,KAAKoH,GAAG5C,EAAEqD,eAGpD2C,GACP1I,EAmBF,OAZAH,GAAgBgJ,YAAc,WAC5B,MAAO,IAAIN,GAAsBrK,OAGrC2B,EAAgBiJ,aAAejJ,EAAgBkJ,WAAa,SAASpF,EAAUL,EAAgBC,GAC3F,MAAO,IAAIrD,GAAkBhC,KAAMyF,EAAUL,EAAgBC,GAASsF,eAG1EhJ,EAAgBmJ,yBAA2BnJ,EAAgBoJ,qBAAuB,SAASC,EAAOvF,EAAUL,EAAgBC,GACxH,MAAO,IAAIrD,GAAkBhC,KAAMyF,EAAUL,EAAgBC,GAAS4F,MAAMD,IAGvE3K"}
|
