{"version":3,"file":"rx.async.min.js","sources":["rx.async.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","createListener","element","handler","addEventListener","disposableCreate","removeEventListener","Error","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","innerHandler","returnValue","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,GAAgBC,EAASN,EAAMO,GACtC,GAAID,EAAQE,iBAEV,MADAF,GAAQE,iBAAiBR,EAAMO,GAAS,GACjCE,EAAiB,WACtBH,EAAQI,oBAAoBV,EAAMO,GAAS,IAG/C,MAAM,IAAII,OAAM,qBAGlB,QAASC,GAAqBC,EAAIC,EAAWP,GAC3C,GAAIQ,GAAc,GAAIC,EAGtB,IAA2C,sBAAvC9B,OAAO+B,UAAUC,SAAS5D,KAAKuD,GACjC,IAAK,GAAItB,GAAI,EAAGC,EAAMqB,EAAG1B,OAAYK,EAAJD,EAASA,IACxCwB,EAAYI,IAAIP,EAAoBC,EAAGO,KAAK7B,GAAIuB,EAAWP,QAEpDM,IACTE,EAAYI,IAAId,EAAeQ,EAAIC,EAAWP,GAGhD,OAAOQ,GAlZT,GAAIM,GAAajE,EAAGiE,WAElBC,GADkBD,EAAWJ,UACLI,EAAWE,aACnCC,EAAkBH,EAAWI,eAC7BC,EAAsBtE,EAAGsE,oBACzBC,EAAevE,EAAGuE,aAClBlB,EAAmBrD,EAAGwE,WAAWC,OACjCb,EAAsB5D,EAAG4D,oBAEzB3B,GADqBjC,EAAG0E,UAAUC,UACf3E,EAAG0E,UAAUE,SAChCC,EAAc7E,EAAG8E,QAAQD,YACzBE,EAAQxE,MAAMsD,UAAUkB,MAEtB9D,EAAW,WACX6B,EAAc,QAyGdnC,EAAkBX,EAAGgF,MAAQ,SAAU3D,GACzC,GAAI4D,GAAWvE,EAAoBW,EAEnC,OAAO,UAAUF,GAiBf,QAAS+D,GAAKxD,EAAKC,GACjBM,EAAiBC,SAASf,EAAKgE,KAAK7E,EAAKoB,EAAKC,IAGhD,QAASkB,GAAKnB,EAAKC,GACjB,GAAIyD,EAOJ,IAJIC,UAAUtD,OAAS,IACrBJ,EAAMoD,EAAM7E,KAAKmF,UAAW,IAG1B3D,EACF,IACE0D,EAAME,EAAIxC,GAAapB,GACvB,MAAOE,GACP,MAAOsD,GAAKtD,GAIhB,IAAKF,EACH,IACE0D,EAAME,EAAIzC,KAAKlB,GACf,MAAOC,GACP,MAAOsD,GAAKtD,GAIhB,GAAIwD,EAAIjE,KACN,MAAO+D,GAAK,KAAME,EAAI9C,MAKxB,IAFA8C,EAAI9C,MAAQlC,EAAQgF,EAAI9C,MAAOhC,SAEpB8E,GAAI9C,QAAUrB,EAyBzB4B,EAAK,GAAI0C,WAAU,iFAzBnB,CACE,GAAIC,IAAS,CACb,KACEJ,EAAI9C,MAAMpC,KAAKI,EAAK,WACdkF,IAIJA,GAAS,EACT3C,EAAK4C,MAAMnF,EAAK+E,cAElB,MAAOzD,GACPK,EAAiBC,SAAS,WACpBsD,IAIJA,GAAS,EACT3C,EAAK3C,KAAKI,EAAKsB,QApEvB,GAAItB,GAAMhB,KACRgG,EAAMjE,CAER,IAAI4D,EAAU,CACZ,GAAIS,GAAOX,EAAM7E,KAAKmF,WACpBjD,EAAMsD,EAAK3D,OACX4D,EAAcvD,SAAcsD,GAAKtD,EAAM,KAAOnB,CAEhDE,GAAOwE,EAAcD,EAAKE,MAAQ5C,EAClCsC,EAAMjE,EAAGoE,MAAMnG,KAAMoG,OAErBvE,GAAOA,GAAQ6B,CAGjBH,MAuEJ7C,GAAG6F,SAAW,SAAUxE,GACtB,MAAO,YACL,GACEG,GACAgE,EACAM,EAHEJ,EAAOX,EAAM7E,KAAKmF,UAgBtB,OAXAK,GAAKK,KAAK,WACRvE,EAAU6D,UAENS,IAAaN,IACfA,GAAS,EACTQ,GAAGP,MAAMnG,KAAMkC,MAInBH,EAAGoE,MAAMnG,KAAMoG,GAER,SAAUrE,GACfyE,EAAWzE,EAEPG,IAAYgE,IACdA,GAAS,EACTnE,EAAGoE,MAAMnG,KAAMkC,OA8BvByC,EAAWgC,MAAQ,SAAUC,EAAMC,EAASC,GAC1C,MAAOC,GAAkBH,EAAMC,EAASC,KAU1C,IAAIC,GAAoBpC,EAAWqC,QAAU,SAAUJ,EAAMC,EAASC,GAEpE,MADAvB,GAAYuB,KAAeA,EAAYnE,GAChC,WACL,GAAIyD,GAAOL,UACTkB,EAAU,GAAIhC,EAahB,OAXA6B,GAAUlE,SAAS,WACjB,GAAIsE,EACJ,KACEA,EAASN,EAAKT,MAAMU,EAAST,GAC7B,MAAO9D,GAEP,WADA2E,GAAQE,QAAQ7E,GAGlB2E,EAAQG,OAAOF,GACfD,EAAQI,gBAEHJ,EAAQK,gBAYnB3C,GAAW4C,aAAe,SAAUX,EAAMC,EAASW,GACjD,MAAO,YACL,GAAIpB,GAAOX,EAAM7E,KAAKmF,UAAW,EAEjC,OAAO,IAAIf,GAAoB,SAAUyC,GACvC,QAAS5D,KACP,GAAI3B,GAAU6D,SAEd,IAAIyB,EAAU,CACZ,IACEtF,EAAUsF,EAAStF,GACnB,MAAOE,GAEP,WADAqF,GAASN,QAAQ/E,GAInBqF,EAASL,OAAOlF,OAEZA,GAAQO,QAAU,EACpBgF,EAASL,OAAOjB,MAAMsB,EAAUvF,GAEhCuF,EAASL,OAAOlF,EAIpBuF,GAASJ,cAGXjB,EAAKK,KAAK5C,GACV+C,EAAKT,MAAMU,EAAST,KACnBsB,cAAcC,aAWrBhD,EAAWiD,iBAAmB,SAAUhB,EAAMC,EAASW,GACrD,MAAO,YACL,GAAIpB,GAAOX,EAAM7E,KAAKmF,UAAW,EAEjC,OAAO,IAAIf,GAAoB,SAAUyC,GACvC,QAAS5D,GAAQzB,GACf,GAAIA,EAEF,WADAqF,GAASN,QAAQ/E,EAInB,IAAIF,GAAUuD,EAAM7E,KAAKmF,UAAW,EAEpC,IAAIyB,EAAU,CACZ,IACEtF,EAAUsF,EAAStF,GACnB,MAAOI,GAEP,WADAmF,GAASN,QAAQ7E,GAGnBmF,EAASL,OAAOlF,OAEZA,GAAQO,QAAU,EACpBgF,EAASL,OAAOjB,MAAMsB,EAAUvF,GAEhCuF,EAASL,OAAOlF,EAIpBuF,GAASJ,cAGXjB,EAAKK,KAAK5C,GACV+C,EAAKT,MAAMU,EAAST,KACnBsB,cAAcC,aAgCrBjH,EAAGmH,OAAOC,iBAAkB,CAG5B,IAAIC,GACDjI,EAAKkI,SAAaA,QAAQpE,QAAUoE,QAAQpE,QAC3C9D,EAAKmI,OAASnI,EAAKmI,OAClBnI,EAAKoI,MAAQpI,EAAKoI,MAAQ,KAG3BC,IAAUrI,EAAKsI,OAA2C,kBAA3BtI,GAAKsI,MAAMC,YAI1CC,IAAexI,EAAKyI,YAAczI,EAAKyI,SAASC,UAapD7D,GAAW8D,UAAY,SAAU7E,EAASQ,EAAWoD,GAEnD,GAAI5D,EAAQyE,YACV,MAAOK,GACL,SAAUC,GAAK/E,EAAQyE,YAAYjE,EAAWuE,IAC9C,SAAUA,GAAK/E,EAAQgF,eAAexE,EAAWuE,IACjDnB,EAIJ,KAAK9G,EAAGmH,OAAOC,gBAAiB,CAC9B,GAAIQ,EACF,MAAOI,GACL,SAAUC,GAAK/E,EAAQiF,GAAGzE,EAAWuE,IACrC,SAAUA,GAAK/E,EAAQkF,IAAI1E,EAAWuE,IACtCnB,EAEJ,IAAIW,EACF,MAAOO,GACL,SAAUC,GAAKP,MAAMC,YAAYzE,EAASQ,EAAWuE,IACrD,SAAUA,GAAKP,MAAMQ,eAAehF,EAASQ,EAAWuE,IACxDnB,EAEJ,IAAIO,EAAI,CACN,GAAIgB,GAAQhB,EAAGnE,EACf,OAAO8E,GACL,SAAUC,GAAKI,EAAMF,GAAGzE,EAAWuE,IACnC,SAAUA,GAAKI,EAAMD,IAAI1E,EAAWuE,IACpCnB,IAGN,MAAO,IAAIxC,GAAoB,SAAUyC,GACvC,MAAOvD,GACLN,EACAQ,EACA,SAAkB9B,GAChB,GAAIJ,GAAUI,CAEd,IAAIkF,EACF,IACEtF,EAAUsF,EAASzB,WACnB,MAAO3D,GAEP,WADAqF,GAASN,QAAQ/E,GAKrBqF,EAASL,OAAOlF,OAEnB8G,UAAUrB,WAUf,IAAIe,GAAmB/D,EAAW+D,iBAAmB,SAAUO,EAAYC,EAAe1B,GACxF,MAAO,IAAIxC,GAAoB,SAAUyC,GACvC,QAAS0B,GAAc7G,GACrB,GAAI4E,GAAS5E,CACb,IAAIkF,EACF,IACEN,EAASM,EAASzB,WAClB,MAAO3D,GAEP,WADAqF,GAASN,QAAQ/E,GAIrBqF,EAASL,OAAOF,GAGlB,GAAIkC,GAAcH,EAAWE,EAC7B,OAAOpF,GAAiB,WAClBmF,GACFA,EAAcC,EAAcC,OAG/BJ,UAAUrB,WAkBb,OAVFhD,GAAW0E,WAAa,SAAUC,GAChC,GAAIlG,EACJ,KACEA,EAAUkG,IACV,MAAOhH,GACP,MAAOwC,GAAgBxC,GAEzB,MAAOsC,GAAsBxB,IAGtB1C"}