{"version":3,"file":"rx.async.compat.min.js","sources":["rx.async.compat.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","toThunk","obj","ctx","Array","isArray","objectToThunk","isGeneratorFunction","observableSpawn","isGenerator","isObservable","observableToThunk","isPromise","promiseToThunk","fnString","isObject","done","run","fn","key","finished","results","pending","err","res","e","keys","Object","length","constructor","timeoutScheduler","schedule","i","len","observable","value","hasValue","subscribe","v","promise","then","name","next","throwString","handleError","fixEvent","event","stopPropagation","cancelBubble","preventDefault","bubbledKeyCode","keyCode","ctrlKey","defaultPrevented","returnValue","modified","target","srcElement","type","relatedTarget","fromElement","toElement","c","charCode","keyChar","String","fromCharCode","createListener","element","handler","addEventListener","disposableCreate","removeEventListener","attachEvent","innerHandler","detachEvent","createEventListener","el","eventName","disposables","CompositeDisposable","prototype","toString","add","item","Observable","observableFromPromise","fromPromise","observableThrow","throwError","AnonymousObservable","AsyncSubject","Disposable","create","Scheduler","immediate","timeout","isScheduler","helpers","slice","internals","spawn","isGenFun","exit","bind","ret","arguments","push","gen","TypeError","called","apply","args","hasCallback","pop","start","func","context","scheduler","observableToAsync","toAsync","subject","result","onError","onNext","onCompleted","asObservable","fromCallback","selector","observer","publishLast","refCount","fromNodeCallback","config","useNativeEvents","fromEvent","addListener","fromEventPattern","h","removeListener","on","off","publish","addHandler","removeHandler","startAsync","functionAsync"],"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,aAAc,WAAY,SAAUE,EAAIR,GAE5C,MADAJ,GAAKY,GAAKpB,EAAQQ,EAAMI,EAASQ,GAC1BZ,EAAKY,KAES,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,GAoBhC,QAASI,GAAQC,EAAKC,GACpB,MAAIC,OAAMC,QAAQH,GAAgBI,EAAcP,KAAKI,EAAKD,GACtDK,EAAoBL,GAAeM,EAAgBN,EAAIH,KAAKI,IAC5DM,EAAYP,GAAgBM,EAAgBN,GAC5CQ,EAAaR,GAAeS,EAAkBT,GAC9CU,UAAUV,GAAeW,EAAeX,SACjCA,KAAQY,EAAmBZ,EAClCa,EAASb,IAAQE,MAAMC,QAAQH,GAAeI,EAAcP,KAAKI,EAAKD,GAEnEA,EAGT,QAASI,GAAcJ,GACrB,GAAIC,GAAMhB,IAEV,OAAO,UAAU6B,GAef,QAASC,GAAIC,EAAIC,GACf,IAAIC,EACJ,IAGE,GAFAF,EAAKjB,EAAQiB,EAAIf,SAENe,KAAOJ,EAEhB,MADAO,GAAQF,GAAOD,IACNI,GAAWN,EAAK,KAAMK,EAGjCH,GAAGnB,KAAKI,EAAK,SAASoB,EAAKC,GACzB,IAAIJ,EAAJ,CAEA,GAAIG,EAEF,MADAH,IAAW,EACJJ,EAAKO,EAGdF,GAAQF,GAAOK,IACbF,GAAWN,EAAK,KAAMK,MAE1B,MAAOI,GACPL,GAAW,EACXJ,EAAKS,IArCT,GAGIL,GAHAM,EAAOC,OAAOD,KAAKxB,GACnBoB,EAAUI,EAAKE,OACfP,EAAU,GAAInB,GAAI2B,WAGtB,KAAKP,EAEH,WADAQ,GAAiBC,SAAS,WAAcf,EAAK,KAAMK,IAIrD,KAAK,GAAIW,GAAI,EAAGC,EAAMP,EAAKE,OAAYK,EAAJD,EAASA,IAC1Cf,EAAIf,EAAIwB,EAAKM,IAAKN,EAAKM,KAgC7B,QAASrB,GAAkBuB,GACzB,MAAO,UAAUhB,GACf,GAAIiB,GAAOC,GAAW,CACtBF,GAAWG,UACT,SAAUC,GACRH,EAAQG,EACRF,GAAW,GAEblB,EACA,WACEkB,GAAYlB,EAAG,KAAMiB,MAK7B,QAAStB,GAAe0B,GACtB,MAAO,UAASrB,GACdqB,EAAQC,KAAK,SAAShB,GACpBN,EAAG,KAAMM,IACRN,IAIP,QAASR,GAAaR,GACpB,MAAOA,UAAcA,GAAImC,YAAcvB,EAGzC,QAASP,GAAoBL,GAC3B,MAAOA,IAAOA,EAAI2B,aAAwC,sBAAzB3B,EAAI2B,YAAYY,KAGnD,QAAShC,GAAYP,GACnB,MAAOA,UAAcA,GAAIwC,OAAS5B,SAAmBZ,GAAIyC,KAAiB7B,EA4F5E,QAAS8B,GAAYrB,GACdA,GACLO,EAAiBC,SAAS,WACxB,KAAMR,KA8IV,QAASsB,GAASC,GAChB,GAAIC,GAAkB,WACpB5D,KAAK6D,cAAe,GAGlBC,EAAiB,WAEnB,GADA9D,KAAK+D,eAAiB/D,KAAKgE,QACvBhE,KAAKiE,QACP,IACEjE,KAAKgE,QAAU,EACf,MAAO1B,IAEXtC,KAAKkE,kBAAmB,EACxBlE,KAAKmE,aAAc,EACnBnE,KAAKoE,UAAW,EAIlB,IADAT,IAAUA,EAAQ7D,EAAK6D,QAClBA,EAAMU,OAeT,OAdAV,EAAMU,OAASV,EAAMU,QAAUV,EAAMW,WAEnB,aAAdX,EAAMY,OACRZ,EAAMa,cAAgBb,EAAMc,aAEZ,YAAdd,EAAMY,OACRZ,EAAMa,cAAgBb,EAAMe,WAGzBf,EAAMC,kBACTD,EAAMC,gBAAkBA,EACxBD,EAAMG,eAAiBA,GAGjBH,EAAMY,MACZ,IAAK,WACH,GAAII,GAAK,YAAchB,GAAQA,EAAMiB,SAAWjB,EAAMK,OAC7C,KAALW,GACFA,EAAI,EACJhB,EAAMK,QAAU,IACF,IAALW,GAAgB,IAALA,EACpBA,EAAI,EACU,GAALA,IACTA,EAAI,IAENhB,EAAMiB,SAAWD,EACjBhB,EAAMkB,QAAUlB,EAAMiB,SAAWE,OAAOC,aAAapB,EAAMiB,UAAY,GAK7E,MAAOjB,GAGT,QAASqB,GAAgBC,EAAS3B,EAAM4B,GAEtC,GAAID,EAAQE,iBAEV,MADAF,GAAQE,iBAAiB7B,EAAM4B,GAAS,GACjCE,EAAiB,WACtBH,EAAQI,oBAAoB/B,EAAM4B,GAAS,IAG/C,IAAID,EAAQK,YAAa,CAEvB,GAAIC,GAAe,SAAU5B,GAC3BuB,EAAQxB,EAASC,IAGnB,OADAsB,GAAQK,YAAY,KAAOhC,EAAMiC,GAC1BH,EAAiB,WACtBH,EAAQO,YAAY,KAAOlC,EAAMiC,KAKrC,MADAN,GAAQ,KAAO3B,GAAQ4B,EAChBE,EAAiB,WACtBH,EAAQ,KAAO3B,GAAQ,OAI3B,QAASmC,GAAqBC,EAAIC,EAAWT,GAC3C,GAAIU,GAAc,GAAIC,EAGtB,IAA2C,sBAAvCrD,OAAOsD,UAAUC,SAASnF,KAAK8E,GACjC,IAAK,GAAI7C,GAAI,EAAGC,EAAM4C,EAAGjD,OAAYK,EAAJD,EAASA,IACxC+C,EAAYI,IAAIP,EAAoBC,EAAGO,KAAKpD,GAAI8C,EAAWT,QAEpDQ,IACTE,EAAYI,IAAIhB,EAAeU,EAAIC,EAAWT,GAGhD,OAAOU,GAnbT,GAAIM,GAAaxF,EAAGwF,WAElBC,GADkBD,EAAWJ,UACLI,EAAWE,aACnCC,EAAkBH,EAAWI,WAC7BC,EAAsB7F,EAAG6F,oBACzBC,EAAe9F,EAAG8F,aAClBpB,EAAmB1E,EAAG+F,WAAWC,OACjCb,EAAsBnF,EAAGmF,oBAEzBlD,GADqBjC,EAAGiG,UAAUC,UACflG,EAAGiG,UAAUE,SAChCC,EAAcpG,EAAGqG,QAAQD,YAGvBnF,GAFMV,MAAM6E,UAAUkB,MAEX,YACXxD,EAAc,QACd5B,EAAWlB,EAAGuG,UAAUrF,SAqGxBP,EAAkBX,EAAGwG,MAAQ,SAAUnF,GACzC,GAAIoF,GAAW/F,EAAoBW,EAEnC,OAAO,UAAUF,GAiBf,QAASuF,GAAKhF,EAAKC,GACjBM,EAAiBC,SAASf,EAAKwF,KAAKrG,EAAKoB,EAAKC,IAGhD,QAASkB,GAAKnB,EAAKC,GACjB,GAAIiF,EAGJ,IAAIC,UAAU9E,OAAS,EACrB,IAAI,GAAIJ,MAAUQ,EAAI,EAAGC,EAAMyE,UAAU9E,OAAYK,EAAJD,EAASA,IAAOR,EAAImF,KAAKD,UAAU1E,GAGtF,IAAIT,EACF,IACEkF,EAAMG,EAAIjE,GAAapB,GACvB,MAAOE,GACP,MAAO8E,GAAK9E,GAIhB,IAAKF,EACH,IACEkF,EAAMG,EAAIlE,KAAKlB,GACf,MAAOC,GACP,MAAO8E,GAAK9E,GAIhB,GAAIgF,EAAIzF,KACN,MAAOuF,GAAK,KAAME,EAAItE,MAKxB,IAFAsE,EAAItE,MAAQlC,EAAQwG,EAAItE,MAAOhC,SAEpBsG,GAAItE,QAAUrB,EAyBzB4B,EAAK,GAAImE,WAAU,iFAzBnB,CACE,GAAIC,IAAS,CACb,KACEL,EAAItE,MAAMpC,KAAKI,EAAK,WACd2G,IAIJA,GAAS,EACTpE,EAAKqE,MAAM5G,EAAKuG,cAElB,MAAOjF,GACPK,EAAiBC,SAAS,WACpB+E,IAIJA,GAAS,EACTpE,EAAK3C,KAAKI,EAAKsB,QApEvB,GAAItB,GAAMhB,KACRyH,EAAM1F,CAER,IAAIoF,EAAU,CACZ,IAAI,GAAIU,MAAWhF,EAAI,EAAGC,EAAMyE,UAAU9E,OAAYK,EAAJD,EAASA,IAAOgF,EAAKL,KAAKD,UAAU1E,GACtF,IAAIC,GAAM+E,EAAKpF,OACbqF,EAAchF,SAAc+E,GAAK/E,EAAM,KAAOnB,CAEhDE,GAAOiG,EAAcD,EAAKE,MAAQtE,EAClCgE,EAAM1F,EAAG6F,MAAM5H,KAAM6H,OAErBhG,GAAOA,GAAQ4B,CAGjBF,MA0FJ2C,GAAW8B,MAAQ,SAAUC,EAAMC,EAASC,GAC1C,MAAOC,GAAkBH,EAAMC,EAASC,KAU1C,IAAIC,GAAoBlC,EAAWmC,QAAU,SAAUJ,EAAMC,EAASC,GAEpE,MADArB,GAAYqB,KAAeA,EAAYxF,GAChC,WACL,GAAIkF,GAAON,UACTe,EAAU,GAAI9B,EAahB,OAXA2B,GAAUvF,SAAS,WACjB,GAAI2F,EACJ,KACEA,EAASN,EAAKL,MAAMM,EAASL,GAC7B,MAAOvF,GAEP,WADAgG,GAAQE,QAAQlG,GAGlBgG,EAAQG,OAAOF,GACfD,EAAQI,gBAEHJ,EAAQK,gBAYnBzC,GAAW0C,aAAe,SAAUX,EAAMC,EAASW,GACjD,MAAO,YAEL,IAAI,GADA/F,GAAMyE,UAAU9E,OAAQoF,EAAO,GAAI5G,OAAM6B,GACrCD,EAAI,EAAOC,EAAJD,EAASA,IAAOgF,EAAKhF,GAAK0E,UAAU1E,EAEnD,OAAO,IAAI0D,GAAoB,SAAUuC,GACvC,QAAS5D,KAEP,IAAI,GADApC,GAAMyE,UAAU9E,OAAQP,EAAU,GAAIjB,OAAM6B,GACxCD,EAAI,EAAOC,EAAJD,EAASA,IAAOX,EAAQW,GAAK0E,UAAU1E,EAEtD,IAAIgG,EAAU,CACZ,IACE3G,EAAU2G,EAASjB,MAAMM,EAAShG,GAClC,MAAOI,GACP,MAAOwG,GAASN,QAAQlG,GAG1BwG,EAASL,OAAOvG,OAEZA,GAAQO,QAAU,EACpBqG,EAASL,OAAOb,MAAMkB,EAAU5G,GAEhC4G,EAASL,OAAOvG,EAIpB4G,GAASJ,cAGXb,EAAKL,KAAKtC,GACV+C,EAAKL,MAAMM,EAASL,KACnBkB,cAAcC,aAWrB9C,EAAW+C,iBAAmB,SAAUhB,EAAMC,EAASW,GACrD,MAAO,YAEL,IAAI,GADA/F,GAAMyE,UAAU9E,OAAQoF,EAAO,GAAI5G,OAAM6B,GACrCD,EAAI,EAAOC,EAAJD,EAASA,IAAOgF,EAAKhF,GAAK0E,UAAU1E,EAEnD,OAAO,IAAI0D,GAAoB,SAAUuC,GACvC,QAAS5D,GAAQ9C,GACf,GAAIA,EAEF,WADA0G,GAASN,QAAQpG,EAKnB,KAAI,GADAU,GAAMyE,UAAU9E,OAAQP,KACpBW,EAAI,EAAOC,EAAJD,EAASA,IAAOX,EAAQW,EAAI,GAAK0E,UAAU1E,EAE1D,IAAIgG,EAAU,CACZ,IACE3G,EAAU2G,EAASjB,MAAMM,EAAShG,GAClC,MAAOI,GACP,MAAOwG,GAASN,QAAQlG,GAE1BwG,EAASL,OAAOvG,OAEZA,GAAQO,QAAU,EACpBqG,EAASL,OAAOb,MAAMkB,EAAU5G,GAEhC4G,EAASL,OAAOvG,EAIpB4G,GAASJ,cAGXb,EAAKL,KAAKtC,GACV+C,EAAKL,MAAMM,EAASL,KACnBkB,cAAcC,aAoGrBtI,EAAGwI,OAAOC,iBAAkB,EAa5BjD,EAAWkD,UAAY,SAAUnE,EAASU,EAAWkD,GAEnD,MAAI5D,GAAQoE,YACHC,EACL,SAAUC,GAAKtE,EAAQoE,YAAY1D,EAAW4D,IAC9C,SAAUA,GAAKtE,EAAQuE,eAAe7D,EAAW4D,IACjDV,GAICnI,EAAGwI,OAAOC,iBAEa,kBAAflE,GAAQwE,IAA4C,kBAAhBxE,GAAQyE,IAOlD,GAAInD,GAAoB,SAAUuC,GACvC,MAAOrD,GACLR,EACAU,EACA,SAAkBrD,GAChB,GAAIJ,GAAUI,CAEd,IAAIuG,EACF,IACE3G,EAAU2G,EAAStB,WACnB,MAAOnF,GACP,MAAO0G,GAASN,QAAQpG,GAI5B0G,EAASL,OAAOvG,OAEnByH,UAAUX,WAvBFM,EACL,SAAUC,GAAKtE,EAAQwE,GAAG9D,EAAW4D,IACrC,SAAUA,GAAKtE,EAAQyE,IAAI/D,EAAW4D,IACtCV,GA8BR,IAAIS,GAAmBpD,EAAWoD,iBAAmB,SAAUM,EAAYC,EAAehB,GACxF,MAAO,IAAItC,GAAoB,SAAUuC,GACvC,QAASvD,GAAcjD,GACrB,GAAIiG,GAASjG,CACb,IAAIuG,EACF,IACEN,EAASM,EAAStB,WAClB,MAAOnF,GACP,MAAO0G,GAASN,QAAQpG,GAG5B0G,EAASL,OAAOF,GAGlB,GAAIpE,GAAcyF,EAAWrE,EAC7B,OAAOH,GAAiB,WAClByE,GACFA,EAActE,EAAcpB,OAG/BwF,UAAUX,WAkBb,OAVF9C,GAAW4D,WAAa,SAAUC,GAChC,GAAI3G,EACJ,KACEA,EAAU2G,IACV,MAAOzH,GACP,MAAO+D,GAAgB/D,GAEzB,MAAO6D,GAAsB/C,IAGtB1C"}