{"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","val","error","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","throwException","AnonymousObservable","AsyncSubject","Disposable","create","Scheduler","immediate","timeout","isScheduler","helpers","slice","spawn","isGenFun","exit","bind","ret","arguments","gen","TypeError","called","apply","args","hasCallback","pop","denodify","callback","push","cb","start","func","context","scheduler","observableToAsync","toAsync","subject","result","onError","onNext","onCompleted","asObservable","fromCallback","selector","observer","publishLast","refCount","fromNodeCallback","config","useNativeEvents","jq","angular","jQuery","Zepto","ember","Ember","addListener","marionette","Backbone","Marionette","fromEvent","fromEventPattern","h","removeListener","on","off","$elem","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,GAmBhC,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,EAG5E,QAASC,GAAS6B,GAChB,MAAOA,IAAOA,EAAIf,cAAgBF,OA8HpC,QAASkB,GAAMtB,GACRA,GACLO,EAAiBC,SAAS,WACxB,KAAMR,KA4IV,QAASuB,GAASC,GAChB,GAAIC,GAAkB,WACpB7D,KAAK8D,cAAe,GAGlBC,EAAiB,WAEnB,GADA/D,KAAKgE,eAAiBhE,KAAKiE,QACvBjE,KAAKkE,QACP,IACElE,KAAKiE,QAAU,EACf,MAAO3B,IAEXtC,KAAKmE,kBAAmB,EACxBnE,KAAKoE,aAAc,EACnBpE,KAAKqE,UAAW,EAIlB,IADAT,IAAUA,EAAQ9D,EAAK8D,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,EAAS5B,EAAM6B,GAEtC,GAAID,EAAQE,iBAEV,MADAF,GAAQE,iBAAiB9B,EAAM6B,GAAS,GACjCE,EAAiB,WACtBH,EAAQI,oBAAoBhC,EAAM6B,GAAS,IAG/C,IAAID,EAAQK,YAAa,CAEvB,GAAIC,GAAe,SAAU5B,GAC3BuB,EAAQxB,EAASC,IAGnB,OADAsB,GAAQK,YAAY,KAAOjC,EAAMkC,GAC1BH,EAAiB,WACtBH,EAAQO,YAAY,KAAOnC,EAAMkC,KAKrC,MADAN,GAAQ,KAAO5B,GAAQ6B,EAChBE,EAAiB,WACtBH,EAAQ,KAAO5B,GAAQ,OAI3B,QAASoC,GAAqBC,EAAIC,EAAWT,GAC3C,GAAIU,GAAc,GAAIC,EAGtB,IAA2C,sBAAvCtD,OAAOuD,UAAUC,SAASpF,KAAK+E,GACjC,IAAK,GAAI9C,GAAI,EAAGC,EAAM6C,EAAGlD,OAAYK,EAAJD,EAASA,IACxCgD,EAAYI,IAAIP,EAAoBC,EAAGO,KAAKrD,GAAI+C,EAAWT,QAEpDQ,IACTE,EAAYI,IAAIhB,EAAeU,EAAIC,EAAWT,GAGhD,OAAOU,GAtdT,GAAIM,GAAazF,EAAGyF,WAElBC,GADkBD,EAAWJ,UACLI,EAAWE,aACnCC,EAAkBH,EAAWI,eAC7BC,EAAsB9F,EAAG8F,oBACzBC,EAAe/F,EAAG+F,aAClBpB,EAAmB3E,EAAGgG,WAAWC,OACjCb,EAAsBpF,EAAGoF,oBAEzBnD,GADqBjC,EAAGkG,UAAUC,UACfnG,EAAGkG,UAAUE,SAChCC,EAAcrG,EAAGsG,QAAQD,YACzBE,EAAQhG,MAAM8E,UAAUkB,MAEtBtF,EAAW,WACX6B,EAAc,QAyGdnC,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,EAOJ,IAJIC,UAAU9E,OAAS,IACrBJ,EAAM4E,EAAMrG,KAAK2G,UAAW,IAG1BnF,EACF,IACEkF,EAAME,EAAIhE,GAAapB,GACvB,MAAOE,GACP,MAAO8E,GAAK9E,GAIhB,IAAKF,EACH,IACEkF,EAAME,EAAIjE,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,GAAIkE,WAAU,iFAzBnB,CACE,GAAIC,IAAS,CACb,KACEJ,EAAItE,MAAMpC,KAAKI,EAAK,WACd0G,IAIJA,GAAS,EACTnE,EAAKoE,MAAM3G,EAAKuG,cAElB,MAAOjF,GACPK,EAAiBC,SAAS,WACpB8E,IAIJA,GAAS,EACTnE,EAAK3C,KAAKI,EAAKsB,QApEvB,GAAItB,GAAMhB,KACRwH,EAAMzF,CAER,IAAIoF,EAAU,CACZ,GAAIS,GAAOX,EAAMrG,KAAK2G,WACpBzE,EAAM8E,EAAKnF,OACXoF,EAAc/E,SAAc8E,GAAK9E,EAAM,KAAOnB,CAEhDE,GAAOgG,EAAcD,EAAKE,MAAQpE,EAClC8D,EAAMzF,EAAG4F,MAAM3H,KAAM4H,OAErB/F,GAAOA,GAAQ6B,CAGjBH,MAuEJ7C,GAAGqH,SAAW,SAAUhG,GACtB,MAAO,YACL,GACEG,GACAwF,EACAM,EAHEJ,EAAOX,EAAMrG,KAAK2G,UAgBtB,OAXAK,GAAKK,KAAK,WACR/F,EAAUqF,UAENS,IAAaN,IACfA,GAAS,EACTQ,GAAGP,MAAM3H,KAAMkC,MAInBH,EAAG4F,MAAM3H,KAAM4H,GAER,SAAU7F,GACfiG,EAAWjG,EAEPG,IAAYwF,IACdA,GAAS,EACT3F,EAAG4F,MAAM3H,KAAMkC,OA8BvBiE,EAAWgC,MAAQ,SAAUC,EAAMC,EAASC,GAC1C,MAAOC,GAAkBH,EAAMC,EAASC,KAU1C,IAAIC,GAAoBpC,EAAWqC,QAAU,SAAUJ,EAAMC,EAASC,GAEpE,MADAvB,GAAYuB,KAAeA,EAAY3F,GAChC,WACL,GAAIiF,GAAOL,UACTkB,EAAU,GAAIhC,EAahB,OAXA6B,GAAU1F,SAAS,WACjB,GAAI8F,EACJ,KACEA,EAASN,EAAKT,MAAMU,EAAST,GAC7B,MAAOtF,GAEP,WADAmG,GAAQE,QAAQrG,GAGlBmG,EAAQG,OAAOF,GACfD,EAAQI,gBAEHJ,EAAQK,gBAYnB3C,GAAW4C,aAAe,SAAUX,EAAMC,EAASW,GACjD,MAAO,YACL,GAAIpB,GAAOX,EAAMrG,KAAK2G,UAAW,EAEjC,OAAO,IAAIf,GAAoB,SAAUyC,GACvC,QAAS9D,KACP,GAAIjD,GAAUqF,SAEd,IAAIyB,EAAU,CACZ,IACE9G,EAAU8G,EAAS9G,GACnB,MAAOE,GAEP,WADA6G,GAASN,QAAQvG,GAInB6G,EAASL,OAAO1G,OAEZA,GAAQO,QAAU,EACpBwG,EAASL,OAAOjB,MAAMsB,EAAU/G,GAEhC+G,EAASL,OAAO1G,EAIpB+G,GAASJ,cAGXjB,EAAKK,KAAK9C,GACViD,EAAKT,MAAMU,EAAST,KACnBsB,cAAcC,aAWrBhD,EAAWiD,iBAAmB,SAAUhB,EAAMC,EAASW,GACrD,MAAO,YACL,GAAIpB,GAAOX,EAAMrG,KAAK2G,UAAW,EAEjC,OAAO,IAAIf,GAAoB,SAAUyC,GACvC,QAAS9D,GAAQ/C,GACf,GAAIA,EAEF,WADA6G,GAASN,QAAQvG,EAInB,IAAIF,GAAU+E,EAAMrG,KAAK2G,UAAW,EAEpC,IAAIyB,EAAU,CACZ,IACE9G,EAAU8G,EAAS9G,GACnB,MAAOI,GAEP,WADA2G,GAASN,QAAQrG,GAGnB2G,EAASL,OAAO1G,OAEZA,GAAQO,QAAU,EACpBwG,EAASL,OAAOjB,MAAMsB,EAAU/G,GAEhC+G,EAASL,OAAO1G,EAIpB+G,GAASJ,cAGXjB,EAAKK,KAAK9C,GACViD,EAAKT,MAAMU,EAAST,KACnBsB,cAAcC,aAoGrBzI,EAAG2I,OAAOC,iBAAkB,CAG5B,IAAIC,GACDzJ,EAAK0J,SAAaA,QAAQtE,QAAUsE,QAAQtE,QAC3CpF,EAAK2J,OAAS3J,EAAK2J,OAClB3J,EAAK4J,MAAQ5J,EAAK4J,MAAQ,KAG3BC,IAAU7J,EAAK8J,OAA2C,kBAA3B9J,GAAK8J,MAAMC,YAI1CC,IAAehK,EAAKiK,YAAcjK,EAAKiK,SAASC,UAapD7D,GAAW8D,UAAY,SAAU/E,EAASU,EAAWoD,GAEnD,GAAI9D,EAAQ2E,YACV,MAAOK,GACL,SAAUC,GAAKjF,EAAQ2E,YAAYjE,EAAWuE,IAC9C,SAAUA,GAAKjF,EAAQkF,eAAexE,EAAWuE,IACjDnB,EAIJ,KAAKtI,EAAG2I,OAAOC,gBAAiB,CAC9B,GAAIQ,EACF,MAAOI,GACL,SAAUC,GAAKjF,EAAQmF,GAAGzE,EAAWuE,IACrC,SAAUA,GAAKjF,EAAQoF,IAAI1E,EAAWuE,IACtCnB,EAEJ,IAAIW,EACF,MAAOO,GACL,SAAUC,GAAKP,MAAMC,YAAY3E,EAASU,EAAWuE,IACrD,SAAUA,GAAKP,MAAMQ,eAAelF,EAASU,EAAWuE,IACxDnB,EAEJ,IAAIO,EAAI,CACN,GAAIgB,GAAQhB,EAAGrE,EACf,OAAOgF,GACL,SAAUC,GAAKI,EAAMF,GAAGzE,EAAWuE,IACnC,SAAUA,GAAKI,EAAMD,IAAI1E,EAAWuE,IACpCnB,IAGN,MAAO,IAAIxC,GAAoB,SAAUyC,GACvC,MAAOvD,GACLR,EACAU,EACA,SAAkBtD,GAChB,GAAIJ,GAAUI,CAEd,IAAI0G,EACF,IACE9G,EAAU8G,EAASzB,WACnB,MAAOnF,GAEP,WADA6G,GAASN,QAAQvG,GAKrB6G,EAASL,OAAO1G,OAEnBsI,UAAUrB,WAUf,IAAIe,GAAmB/D,EAAW+D,iBAAmB,SAAUO,EAAYC,EAAe1B,GACxF,MAAO,IAAIxC,GAAoB,SAAUyC,GACvC,QAASzD,GAAclD,GACrB,GAAIoG,GAASpG,CACb,IAAI0G,EACF,IACEN,EAASM,EAASzB,WAClB,MAAOnF,GAEP,WADA6G,GAASN,QAAQvG,GAIrB6G,EAASL,OAAOF,GAGlB,GAAItE,GAAcqG,EAAWjF,EAC7B,OAAOH,GAAiB,WAClBqF,GACFA,EAAclF,EAAcpB,OAG/BoG,UAAUrB,WAkBb,OAVFhD,GAAWwE,WAAa,SAAUC,GAChC,GAAIxH,EACJ,KACEA,EAAUwH,IACV,MAAOtI,GACP,MAAOgE,GAAgBhE,GAEzB,MAAO8D,GAAsBhD,IAGtB1C"}