| 1 | {"version":3,"file":"rx.async.compat.min.js","sources":["rx.async.compat.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","toObservable","obj","Observable","isObservable","isPromise","fromPromise","isGeneratorFunction","isGenerator","spawn","isFunction","thunkToObservable","isArrayLike","isIterable","arrayToObservable","isObject","objectToObservable","from","concatMap","o","just","toArray","defer","observable","key","results","observables","push","map","next","constructor","keys","i","len","length","forkJoin","fn","AnonymousObservable","err","res","onError","args","onNext","onCompleted","ctor","name","displayName","prototype","val","createCbObservable","ctx","selector","AsyncSubject","createCbHandler","asObservable","Array","tryCatch","createNodeObservable","createNodeHandler","isNodeList","el","StaticNodeList","NodeList","toString","ListenDisposable","n","_e","_n","_fn","addEventListener","isDisposed","createEventListener","eventName","handler","disposables","CompositeDisposable","elemToString","add","item","observableFromPromise","observableThrow","throwError","ObservableBase","Disposable","create","defaultScheduler","Scheduler","immediate","inherits","internals","isScheduler","helpers","TypeError","wrap","createObservable","__generatorFunction__","gen","processGenerator","ret","done","obs","hasValue","g","subscribe","start","func","context","scheduler","observableToAsync","toAsync","subject","schedule","result","fromCallback","fromNodeCallback","dispose","removeEventListener","config","useNativeEvents","EventObservable","__super__","_el","createHandler","subscribeCore","fromEvent","element","addListener","fromEventPattern","h","removeListener","on","off","publish","refCount","EventPatternObservable","del","_add","_del","EventPatternDisposable","_ret","returnValue","addHandler","removeHandler","startAsync","functionAsync","promise"],"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,eAAgB,WAAY,SAAUE,EAAIhB,GAEhD,MADAY,GAAKI,GAAKxB,EAAQoB,EAAMZ,EAASgB,GAC1BJ,EAAKI,KAEa,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,GAsBpC,QAASC,GAAcC,GACrB,MAAO,YACL,IACE,MAAOA,GAAeC,MAAMZ,KAAMa,WAClC,MAAOC,GAEP,MADAC,GAASD,EAAIA,EACNC,IA2Eb,QAASC,GAAaC,GACpB,MAAKA,GACDC,EAAWC,aAAaF,GAAeA,EACvCG,EAAUH,GAAeC,EAAWG,YAAYJ,GAChDK,EAAoBL,IAAQM,EAAYN,GAAeO,EAAMjB,KAAKP,KAAMiB,GACxEQ,EAAWR,GAAeS,EAAkBnB,KAAKP,KAAMiB,GACvDU,EAAYV,IAAQW,EAAWX,GAAeY,EAAkBtB,KAAKP,KAAMiB,GAC3Ea,EAASb,GAAcc,EAAmBxB,KAAKP,KAAMiB,GAClDA,EAPYA,EAUrB,QAASY,GAAmBZ,GAC1B,MAAOC,GAAWc,KAAKf,GAAKgB,UAAU,SAASC,GAC7C,MAAGhB,GAAWC,aAAae,IAAMJ,EAASI,GACjClB,EAAaT,KAAK,KAAM2B,GAExB7B,EAAGa,WAAWiB,KAAKD,KAE3BE,UAGL,QAASL,GAAoBd,GAkB3B,QAASoB,GAAOC,EAAYC,GAC1BC,EAAQD,GAAO9B,EACfgC,EAAYC,KAAKJ,EAAWK,IAAI,SAAUC,GACxCJ,EAAQD,GAAOK,KAnBnB,IAAK,GADDJ,GAAU,GAAIvB,GAAI4B,YAAeC,EAAO9D,OAAO8D,KAAK7B,GAAMwB,KACrDM,EAAI,EAAGC,EAAMF,EAAKG,OAAYD,EAAJD,EAASA,IAAK,CAC/C,GAAIR,GAAMO,EAAKC,GACXT,EAAatB,EAAaT,KAAKP,KAAMiB,EAAIsB,GAE1CD,IAAcpB,EAAWC,aAAamB,GACvCD,EAAMC,EAAYC,GAElBC,EAAQD,GAAOtB,EAAIsB,GAIvB,MAAOrB,GAAWgC,SAAStC,MAAMM,EAAYuB,GAAaE,IAAI,WAC5D,MAAOH,KAYX,QAASd,GAAkByB,GACzB,GAAIvD,GAAOI,IACX,OAAO,IAAIoD,GAAoB,SAAUlB,GACvCiB,EAAG5C,KAAKX,EAAM,WACZ,GAAIyD,GAAMxC,UAAU,GAAIyC,EAAMzC,UAAU,EACxC,IAAIwC,EAAO,MAAOnB,GAAEqB,QAAQF,EAC5B,IAAIxC,UAAUoC,OAAS,EAAG,CAExB,IAAK,GADDO,MACKT,EAAI,EAAGC,EAAMnC,UAAUoC,OAAYD,EAAJD,EAASA,IAAOS,EAAKd,KAAK7B,UAAUkC,GAC5EO,GAAME,EAERtB,EAAEuB,OAAOH,GACTpB,EAAEwB,kBAKR,QAASnC,GAAYN,GACnB,MAAOQ,GAAYR,EAAI2B,OAASnB,EAAYR,EAAI,UAGlD,QAASK,GAAoBL,GAC3B,GAAI0C,GAAO1C,EAAI4B,WACf,OAAKc,GACa,sBAAdA,EAAKC,MAAqD,sBAArBD,EAAKE,aAA8C,EACrFtC,EAAYoC,EAAKG,YAFJ,EAKtB,QAAShC,GAASiC,GAChB,MAAO/E,SAAU+E,EAAIlB,YAoDzB,QAASmB,GAAmBb,EAAIc,EAAKC,EAAUV,GAC7C,GAAItB,GAAI,GAAIiC,EAKZ,OAHAX,GAAKd,KAAK0B,EAAgBlC,EAAG+B,EAAKC,IAClCf,EAAGvC,MAAMqD,EAAKT,GAEPtB,EAAEmC,eAGX,QAASD,GAAgBlC,EAAG+B,EAAKC,GAC/B,MAAO,YAEL,IAAI,GADAlB,GAAMnC,UAAUoC,OAAQT,EAAU,GAAI8B,OAAMtB,GACxCD,EAAI,EAAOC,EAAJD,EAASA,IAAOP,EAAQO,GAAKlC,UAAUkC,EAEtD,IAAItB,EAAWyC,GAAW,CAExB,GADA1B,EAAU+B,EAASL,GAAUtD,MAAMqD,EAAKzB,GACpCA,IAAYzB,EAAY,MAAOmB,GAAEqB,QAAQf,EAAQ1B,EACrDoB,GAAEuB,OAAOjB,OAELA,GAAQS,QAAU,EACpBf,EAAEuB,OAAOjB,EAAQ,IAEjBN,EAAEuB,OAAOjB,EAIbN,GAAEwB,eAsBN,QAASc,GAAqBrB,EAAIc,EAAKC,EAAUV,GAC/C,GAAItB,GAAI,GAAIiC,EAKZ,OAHAX,GAAKd,KAAK+B,EAAkBvC,EAAG+B,EAAKC,IACpCf,EAAGvC,MAAMqD,EAAKT,GAEPtB,EAAEmC,eAGX,QAASI,GAAkBvC,EAAG+B,EAAKC,GACjC,MAAO,YACL,GAAIb,GAAMxC,UAAU,EACpB,IAAIwC,EAAO,MAAOnB,GAAEqB,QAAQF,EAG5B,KAAI,GADAL,GAAMnC,UAAUoC,OAAQT,KACpBO,EAAI,EAAOC,EAAJD,EAASA,IAAOP,EAAQO,EAAI,GAAKlC,UAAUkC,EAE1D,IAAItB,EAAWyC,GAAW,CACxB,GAAI1B,GAAU+B,EAASL,GAAUtD,MAAMqD,EAAKzB,EAC5C,IAAIA,IAAYzB,EAAY,MAAOmB,GAAEqB,QAAQf,EAAQ1B,EACrDoB,GAAEuB,OAAOjB,OAELA,GAAQS,QAAU,EACpBf,EAAEuB,OAAOjB,EAAQ,IAEjBN,EAAEuB,OAAOjB,EAIbN,GAAEwB,eAoBJ,QAASgB,GAAWC,GAClB,MAAI1E,GAAK2E,eAGAD,YAAc1E,GAAK2E,gBAAkBD,YAAc1E,GAAK4E,SAEjB,sBAAvC7F,OAAO8E,UAAUgB,SAASvE,KAAKoE,GAI1C,QAASI,GAAiBjE,EAAGkE,EAAG7B,GAC9BnD,KAAKiF,GAAKnE,EACVd,KAAKkF,GAAKF,EACVhF,KAAKmF,IAAMhC,EACXnD,KAAKiF,GAAGG,iBAAiBpF,KAAKkF,GAAIlF,KAAKmF,KAAK,GAC5CnF,KAAKqF,YAAa,EASpB,QAASC,GAAqBX,EAAIY,EAAWC,GAC3C,GAAIC,GAAc,GAAIC,GAGlBC,EAAe3G,OAAO8E,UAAUgB,SAASvE,KAAKoE,EAClD,IAAID,EAAWC,IAAwB,4BAAjBgB,EACpB,IAAK,GAAI5C,GAAI,EAAGC,EAAM2B,EAAG1B,OAAYD,EAAJD,EAASA,IACxC0C,EAAYG,IAAIN,EAAoBX,EAAGkB,KAAK9C,GAAIwC,EAAWC,QAEpDb,IACTc,EAAYG,IAAI,GAAIb,GAAiBJ,EAAIY,EAAWC,GAGtD,OAAOC,GA1WT,GAAIvE,GAAab,EAAGa,WAClB4E,EAAwB5E,EAAWG,YACnC0E,EAAkB7E,EAAW8E,WAC7B5C,EAAsB/C,EAAG+C,oBACzB6C,EAAiB5F,EAAG4F,eACpB9B,EAAe9D,EAAG8D,aAElBuB,GADmBrF,EAAG6F,WAAWC,OACX9F,EAAGqF,qBAEzBU,GADqB/F,EAAGgG,UAAUC,UACfjG,EAAGgG,UAAU,YAChCE,EAAWlG,EAAGmG,UAAUD,SACxBE,EAAcpG,EAAGgG,UAAUI,YAC3BrF,EAAYf,EAAGqG,QAAQtF,UACvBK,EAAapB,EAAGqG,QAAQjF,WACxBG,EAAavB,EAAGqG,QAAQ9E,WACxBD,EAActB,EAAGqG,QAAQ/E,YAEvBZ,GAAYD,MAaZyD,EAAWlE,EAAGmG,UAAUjC,SAAW,SAAkBpB,GACvD,IAAK1B,EAAW0B,GAAO,KAAM,IAAIwD,WAAU,wBAC3C,OAAOjG,GAAcyC,GAOvBjC,GAAW0F,KAAO,SAAUzD,GAC1B,QAAS0D,KACP,MAAO3F,GAAWM,MAAMjB,KAAKP,KAAMmD,EAAGvC,MAAMZ,KAAMa,YAIpD,MADAgG,GAAiBC,sBAAwB3D,EAClC0D,EAGT,IAAIrF,GAAQN,EAAWM,MAAQ,WAE7B,IAAK,GADDuF,GAAMlG,UAAU,GAAIjB,EAAOI,KAAMwD,KAC5BT,EAAI,EAAGC,EAAMnC,UAAUoC,OAAYD,EAAJD,EAASA,IAAOS,EAAKd,KAAK7B,UAAUkC,GAE5E,OAAO,IAAIK,GAAoB,SAAUlB,GASvC,QAAS8E,GAAiB1D,GACxB,GAAI2D,GAAM1C,EAASwC,EAAInE,MAAMrC,KAAKwG,EAAKzD,EACvC,OAAI2D,KAAQlG,EAAmBmB,EAAEqB,QAAQ0D,EAAInG,OAC7C8B,GAAKqE,GAKP,QAAS1D,GAAQF,GACf,GAAI4D,GAAM1C,EAASwC,EAAInE,MAAMrC,KAAKwG,EAAK1D,EACvC,OAAI4D,KAAQlG,EAAmBmB,EAAEqB,QAAQ0D,EAAInG,OAC7C8B,GAAKqE,GAGP,QAASrE,GAAKqE,GACZ,GAAIA,EAAIC,KAGN,MAFAhF,GAAEuB,OAAOwD,EAAIlI,WACbmD,GAAEwB,aAGJ,IAAIyD,GAAMnG,EAAaT,KAAKX,EAAMqH,EAAIlI,OAClCA,EAAQ,KACRqI,GAAW,CACXlG,GAAWC,aAAagG,GAC1BE,EAAEzB,IAAIuB,EAAIG,UAAU,SAASvD,GAC3BqD,GAAW,EACXrI,EAAQgF,GACPR,EAAS,WACV6D,GAAYJ,EAAiBjI,MAG/BwE,EAAQ,GAAIoD,WAAU,uBAvC1B,GAAIU,GAAI,GAAI3B,EAGZ,OADIjE,GAAWsF,KAAQA,EAAMA,EAAInG,MAAMhB,EAAM4D,IACxCuD,GAAQtF,EAAWsF,EAAInE,OAW5BoE,IA6BOK,IAvCLnF,EAAEuB,OAAOsD,GACF7E,EAAEwB,iBA0IfxC,GAAWqG,MAAQ,SAAUC,EAAMC,EAASC,GAC1C,MAAOC,GAAkBH,EAAMC,EAASC,KAU1C,IAAIC,GAAoBzG,EAAW0G,QAAU,SAAUJ,EAAMC,EAASC,GAEpE,MADAjB,GAAYiB,KAAeA,EAAYtB,GAChC,WACL,GAAI5C,GAAO3C,UACTgH,EAAU,GAAI1D,EAahB,OAXAuD,GAAUI,SAAS,KAAM,WACvB,GAAIC,EACJ,KACEA,EAASP,EAAK5G,MAAM6G,EAASjE,GAC7B,MAAO1C,GAEP,WADA+G,GAAQtE,QAAQzC,GAGlB+G,EAAQpE,OAAOsE,GACfF,EAAQnE,gBAEHmE,EAAQxD,gBA0CrBnD,GAAW8G,aAAe,SAAU7E,EAAIc,EAAKC,GAC3C,MAAO,YACU,mBAARD,KAAwBA,EAAMjE,KAGrC,KAAI,GADAgD,GAAMnC,UAAUoC,OAAQO,EAAO,GAAIc,OAAMtB,GACrCD,EAAI,EAAOC,EAAJD,EAASA,IAAOS,EAAKT,GAAKlC,UAAUkC,EACnD,OAAOiB,GAAmBb,EAAIc,EAAKC,EAAUV,KA4CjDtC,EAAW+G,iBAAmB,SAAU9E,EAAIc,EAAKC,GAC/C,MAAO,YACU,mBAARD,KAAwBA,EAAMjE,KAErC,KAAI,GADAgD,GAAMnC,UAAUoC,OAAQO,EAAO,GAAIc,OAAMtB,GACrCD,EAAI,EAAOC,EAAJD,EAASA,IAAOS,EAAKT,GAAKlC,UAAUkC,EACnD,OAAOyB,GAAqBrB,EAAIc,EAAKC,EAAUV,KAqBjDuB,EAAiBjB,UAAUoE,QAAU,WAC9BlI,KAAKqF,aACRrF,KAAKiF,GAAGkD,oBAAoBnI,KAAKkF,GAAIlF,KAAKmF,KAAK,GAC/CnF,KAAKqF,YAAa,IAuBtBhF,EAAG+H,OAAOC,iBAAkB,CAE5B,IAAIC,GAAmB,SAASC,GAE9B,QAASD,GAAgB3D,EAAIf,EAAMT,GACjCnD,KAAKwI,IAAM7D,EACX3E,KAAKkF,GAAKtB,EACV5D,KAAKmF,IAAMhC,EACXoF,EAAUhI,KAAKP,MAGjB,QAASyI,GAAcvG,EAAGiB,GACxB,MAAO,YACL,GAAIX,GAAU3B,UAAU,EACxB,OAAIY,GAAW0B,KACbX,EAAU+B,EAASpB,GAAIvC,MAAM,KAAMC,WAC/B2B,IAAYzB,GAAmBmB,EAAEqB,QAAQf,EAAQ1B,OAEvDoB,GAAEuB,OAAOjB,IAWb,MA1BA+D,GAAS+B,EAAiBC,GAmB1BD,EAAgBxE,UAAU4E,cAAgB,SAAUxG,GAClD,MAAOoD,GACLtF,KAAKwI,IACLxI,KAAKkF,GACLuD,EAAcvG,EAAGlC,KAAKmF,OAGnBmD,GACPrC,EASF/E,GAAWyH,UAAY,SAAUC,EAASrD,EAAWrB,GAEnD,MAAI0E,GAAQC,YACHC,EACL,SAAUC,GAAKH,EAAQC,YAAYtD,EAAWwD,IAC9C,SAAUA,GAAKH,EAAQI,eAAezD,EAAWwD,IACjD7E,GAIC7D,EAAG+H,OAAOC,iBAEa,kBAAfO,GAAQK,IAA4C,kBAAhBL,GAAQM,IAQlD,GAAIZ,GAAgBM,EAASrD,EAAWrB,GAAUiF,UAAUC,WAPxDN,EACL,SAAUC,GAAKH,EAAQK,GAAG1D,EAAWwD,IACrC,SAAUA,GAAKH,EAAQM,IAAI3D,EAAWwD,IACtC7E,GAOR,IAAImF,GAA0B,SAASd,GAErC,QAASc,GAAuBzD,EAAK0D,EAAKnG,GACxCnD,KAAKuJ,KAAO3D,EACZ5F,KAAKwJ,KAAOF,EACZtJ,KAAKmF,IAAMhC,EACXoF,EAAUhI,KAAKP,MAGjB,QAASyI,GAAcvG,EAAGiB,GACxB,MAAO,YACL,GAAIX,GAAU3B,UAAU,EACxB,OAAIY,GAAW0B,KACbX,EAAU+B,EAASpB,GAAIvC,MAAM,KAAMC,WAC/B2B,IAAYzB,GAAmBmB,EAAEqB,QAAQf,EAAQ1B,OAEvDoB,GAAEuB,OAAOjB,IAUb,QAASiH,GAAuBH,EAAKnG,EAAI8D,GACvCjH,KAAKwJ,KAAOF,EACZtJ,KAAKmF,IAAMhC,EACXnD,KAAK0J,KAAOzC,EACZjH,KAAKqF,YAAa,EASpB,MAtCAkB,GAAS8C,EAAwBd,GAmBjCc,EAAuBvF,UAAU4E,cAAgB,SAAUxG,GACzD,GAAIiB,GAAKsF,EAAcvG,EAAGlC,KAAKmF,KAC3BwE,EAAc3J,KAAKuJ,KAAKpG,EAC5B,OAAO,IAAIsG,GAAuBzJ,KAAKwJ,KAAMrG,EAAIwG,IAUnDF,EAAuB3F,UAAUoE,QAAU,WACrClI,KAAKqF,YACP5D,EAAWzB,KAAKwJ,OAASxJ,KAAKwJ,KAAKxJ,KAAKmF,IAAKnF,KAAK0J,OAI/CL,GACPpD,GASE6C,EAAmB5H,EAAW4H,iBAAmB,SAAUc,EAAYC,EAAe3F,GACxF,MAAO,IAAImF,GAAuBO,EAAYC,EAAe3F,GAAUiF,UAAUC,WAcnF,OANAlI,GAAW4I,WAAa,SAAUC,GAChC,GAAIC,GAAUzF,EAASwF,IACvB,OAAIC,KAAYjJ,EAAmBgF,EAAgBiE,EAAQlJ,GACpDgF,EAAsBkE,IAGxB3J"} |