{"version":3,"file":"rx.wamp.min.js","sources":["rx.wamp.js"],"names":["factory","objectTypes","boolean","function","object","number","string","undefined","root","window","this","freeExports","exports","nodeType","freeModule","module","freeGlobal","global","define","amd","Rx","autobahn","wamp","require","call","exp","_connection_factory","opts","_connection_cls","observableStatic","Observable","observableWamp","WAMP","observableEmpty","empty","observableCreate","create","observablePromise","fromPromise","observerStatic","Observer","observerCreate","Disposable","Subject","CompositeDisposable","SerialDisposable","ab","isPromise","Session","prototype","helpers","noop","_detectVersion","version","Connection","__version","CONNECTION_CLOSED","CONNECTION_UNREACHABLE","CONNECTION_LOST","url","Error","uri","disposable","_onopen","session","setDisposable","close","isDisposed","onopen","open","connect","bind","onclose","dispose","fromConnection","keepReconnecting","isV2Supported","connection","obs","onNext","codeOrReason","reasonOrDetails","details","code","reason","onError","onCompleted","fromSession","options","onhangup","authreqAsObservable","auth","authKey","extras","authreq","flatMap","challenge","fromPubSubPattern","topic","openObserver","PubSubSubject","SubscriptionDisposable","subscriber","disposer","subscription","self","subscriptionSubscription","value","internals","addProperties","TopicDisposable","__super__","subscriptionObservable","observer","subscribe","unsubscribe","handler","inherits","RegistrationDisposable","registrationObservable","unregister","subscribeAsObservable","sessionOrObservable","v2","args","kwargs","next","event","just","flatMapLatest","innerObservable","innerObserver","publish","refCount","publishAsObservable","largs","len","arguments","length","i","push","published","apply","registerAsObservable","procedure","endpoint","register","registration","callAsObservable","_errorObservable","_openObserver","observable","subscribeOnError","Object","defineProperty","get","asObservable","opened","exception","Subscriber","to","observerOrOnNext","add"],"mappings":"CAAE,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,KAAM,WAAY,WAAY,SAAUE,EAAIC,SAAUT,GAE1D,MADAJ,GAAKY,GAAKpB,EAAQQ,EAAMI,EAASQ,EAAIC,UAC9Bb,EAAKY,KAES,gBAAXL,SAAuBA,QAAUA,OAAOH,UAAYD,EAClEI,OAAOH,QAAU,SAASU,GAItB,MAHKA,KACDA,EAAOC,QAAQ,aAEZvB,EAAQQ,EAAMO,OAAOH,QAASW,QAAQ,MAAOD,IAGxDd,EAAKY,GAAKpB,EAAQQ,KAAUA,EAAKY,GAAIZ,EAAKa,YAEhDG,KAAKd,KAAM,SAAUF,EAAMiB,EAAKL,EAAIC,UAuEtC,QAASK,GAAoBC,GACzB,MAAO,IAAIN,UAASO,gBAAgBD,GArExC,GAAIE,GAAmBT,EAAGU,WACtBC,EAAiBX,EAAGY,QACpBC,EAAkBJ,EAAiBK,MACnCC,EAAmBN,EAAiBO,OACpCC,EAAoBR,EAAiBS,YACrCC,EAAiBnB,EAAGoB,SACpBC,EAAiBF,EAAeH,OAEhCM,GADUtB,EAAGuB,QACAvB,EAAGsB,YAChBE,EAAsBxB,EAAGwB,oBACzBC,EAAmBzB,EAAGyB,iBACtBxB,SAAWA,UAAYyB,GAGvBC,GAFe1B,SAAS2B,QAAQC,UAEpB7B,EAAG8B,QAAQH,WACvBI,EAAO/B,EAAG8B,QAAQC,KAElBC,EAAiB,WACjB,MAAoC,kBAArB/B,UAASgC,SAAiD,UAAvBhC,SAASgC,WAA2BhC,SAASiC,WAAc,EAAI,GAGjHC,EAAYH,IAEZI,EAAoBnC,SAASmC,mBAAqB,SAClDC,EAAyBpC,SAASoC,wBAA0B,cAC5DC,EAAkBrC,SAASqC,iBAAmB,MAMlDrC,UAASO,gBAAkBP,SAASiC,YAAc,SAAU3B,GAExD,GAAIgC,EACJ,IAAoB,gBAAThC,GACPgC,EAAMhC,EACNA,SACG,CAAA,GAAoB,gBAATA,GAGd,KAAM,IAAIiC,OAAM,8CAFhBD,GAAMhC,EAAKkC,KAAOlC,EAAKgC,IAK3B,GAAIG,GAAa,GAAIjB,EAErBnC,MAAKqD,QAAU,SAAUC,GAErBF,EAAWG,cAAcvB,EAAWN,OAAO,WACvC4B,EAAQE,YAGPJ,EAAWK,YAAczD,KAAK0D,QAC/B1D,KAAK0D,OAAOJ,IAGpBtD,KAAK2D,KAAO,WACRhD,SAASiD,QAAQX,EAAKjD,KAAKqD,QAAQQ,KAAK7D,MAAOA,KAAK8D,QAAS7C,IAGjEjB,KAAKwD,MAAQ,WACTJ,EAAWW,WAGf/D,KAAK0D,OAAS,KACd1D,KAAK8D,QAAU,MAQnBzC,EAAe2C,eAAiB7C,EAAiB6C,eAAiB,SAAU/C,EAAMgD,EAAkB3E,GAEhG,GAAI4E,GAAgBxB,IAIhByB,GAAc7E,GAAW0B,GAAqBC,EAElD,OAAOE,GAAiBO,OAAO,SAAU0C,GA8BrC,MA5BAD,GAAWT,OAAS,SAAUJ,GAC1Bc,EAAIC,OAAOf,IAGfa,EAAWL,QAAU,SAAUQ,EAAcC,EAAiBC,GAE1D,GAAIC,GAAOH,EACPI,EAASR,EAAgBO,EAAOF,EAChCC,EAAUN,EAAgBK,EAAkBC,CAEhD,QAAQF,GACJ,IAAKvB,GACDqB,EAAIO,SAASD,OAAQA,EAAQF,QAASA,EAASC,KAAMA,GACrD,MACJ,KAAKzB,GACD,IAAKiB,EAAiBR,WAClB,OAAO,CACf,KAAKX,GACL,QACIsB,EAAIQ,cAIZ,OAAO,GAGXT,EAAWR,OAEJ,WACHQ,GAAcA,EAAWX,YASrCnC,EAAewD,YAAc1D,EAAiB0D,YAAc,SAAS5B,EAAK6B,GAEtE,MAAOrD,GAAiB,SAAS2C,GAE7B,QAASV,KACLU,EAAIC,OAAOf,GAGf,QAASyB,GAASN,EAAMC,GAChBD,IAAS3B,EACTsB,EAAIQ,cAEJR,EAAIO,QAAQF,EAAMC,GAG1B,GAAIpB,GAAU,GAAI3C,UAAS2B,QAAQW,EAAKS,EAAQqB,EAAUD,EAE1D,OAAO9C,GAAWN,OAAO,WACrB4B,EAAQE,aAcpBnC,EAAe2D,oBAAsB7D,EAAiB6D,oBAAsB,SAAS1B,EAAS2B,EAAMC,EAASC,GAEzG,MAAOxD,GAAkB2B,EAAQ8B,QAAQF,EAASC,IAC7CE,QAAQ,SAASC,GACd,MAAOL,GAAKnE,KAAKwC,EAASgC,MAQtCjE,EAAekE,kBAAoBpE,EAAiBoE,kBAAoB,SAAUjC,EAASkC,EAAOV,EAASW,GACvG,MAAO,IAAIC,GAAcpC,EAASkC,EAAOV,EAASW,GAGtD,IAAIE,GAAyB,WAEzB,QAASA,GAAuBrC,EAASsC,EAAYC,GACjD7F,KAAKsD,QAAUA,EACftD,KAAK6F,SAAWA,EAChB7F,KAAK8F,aAAe,IACpB,IAAIC,GAAO/F,IACXA,MAAKgG,yBACDJ,EACI7D,EACI,SAASkE,GACLF,EAAKD,aAAeG,GAGxB,WACIF,EAAKhC,aAYzB,MARArD,GAAGwF,UAAUC,cAAcR,EAAuBpD,WAE9CwB,QAAU,WACN/D,KAAKgG,0BAA4BhG,KAAKgG,yBAAyBjC,UAC/D/D,KAAK8F,cAAgB9F,KAAK6F,SAAS/E,KAAKd,KAAMA,KAAKsD,QAAStD,KAAK8F,iBAIlEH,KAGPS,EAAkB,SAAUC,GAU5B,QAASD,GAAgB9C,EAASgD,GAE9BD,EAAUvF,KAAKd,KAAMsD,EACjB,SAASiD,GAAW,MAAOD,GAAuBE,UAAUD,IAC5DV,GAZR,GAAIA,GAAyB,GAAbhD,EACZ,SAASS,EAASwC,GACdxC,EAAQmD,YAAYX,IAExB,SAASxC,EAASwC,GACdxC,EAAQmD,YAAYX,EAAaN,MAAOM,EAAaY,SAY7D,OAFAhG,GAAGwF,UAAUS,SAASP,EAAiBT,GAEhCS,GACRT,GAECiB,EAAyB,SAAUP,GAEnC,QAASO,GAAuBtD,EAASuD,GACrCR,EAAUvF,KAAKd,KAAMsD,EACjB,SAASiD,GAAY,MAAOM,GAAuBL,UAAUD,IAC7D,SAASjD,EAASwC,GAAgBxC,EAAQwD,WAAWhB,KAM7D,MAFApF,GAAGwF,UAAUS,SAASC,EAAwBP,GAEvCO,GAERjB,EAUHtE,GAAe0F,sBAAwB5F,EAAiB4F,sBAAwB,SAA+BC,EAAqBxB,EAAOV,EAASW,GAChJ,GAAIwB,GAAmB,GAAbpE,CACV,OAAOpB,GAAiB,SAAU2C,GAE9B,GAAIsC,GAAWO,EAIX,SAAUC,EAAMC,EAAQ3C,GAEpB,GAAI4C,KACJF,KAASE,EAAKF,KAAOA,GACrBC,IAAWC,EAAKD,OAASA,GACzB3C,IAAY4C,EAAK5C,QAAUA,GAE3BJ,EAAIC,OAAO+C,IAVf,SAAU5B,EAAO6B,GACbjD,EAAIC,QAAQmB,MAAOA,EAAO6B,MAAOA,IAazCL,GAAoBR,WAAaQ,EAAoBP,cAAgBO,EAAsB7F,EAAiBmG,KAAKN,GAGjH,IAcI3C,GAdAiC,EAAyBU,EACxBO,cAAc,SAASjE,GACpB,GAAIwC,GAAexC,EAAQkD,UAAUhB,EAAOkB,EAAS5B,KAAaU,MAAQA,EAAOkB,QAAUA,GACvFc,EAAkBnF,EAAUyD,GAAgBnE,EAAkBmE,GAAgB3E,EAAiBmG,KAAKxB,EAExG,OAAOrE,GAAiB,SAASgG,GAC7B,MAAO,IAAIvF,GACP,GAAIkE,GAAgB9C,EAASkE,GAC7BA,EAAgBhB,UACZiB,EAAcpD,OAAOR,KAAK4D,GAC1BA,EAAc9C,QAAQd,KAAK4D,QAgB/C,OAXIhC,KACyB,kBAAjBA,KAAiCpB,EAASoB,GACzB,gBAAjBA,KAA+BpB,EAASoB,EAAapB,OAAOR,KAAK4B,MAG5EpB,IAAWA,EAAS5B,GAMd6D,EAAuBE,UAC1BnC,EACAD,EAAIO,QAAQd,KAAKO,MAEtBsD,UAAUC,YAGjBtG,EAAeuG,oBAAsBzG,EAAiByG,oBAAsB,SAAUtE,GAGlF,IAAK,GAFDuE,MAAYC,EAAMC,UAAUC,OAEvBC,EAAI,EAAOH,EAAJG,IAAWA,EAAGJ,EAAMK,KAAKH,UAAUE,GACnD,IAAIE,GAAY7E,EAAQoE,QAAQU,MAAM9E,EAASuE,EAC/C,OAAOM,GAAYxG,EAAkBwG,GAAa5G,KAGtDF,EAAegH,qBAAuBlH,EAAiBkH,qBAAuB,SAAUrB,EAAqBsB,EAAWC,EAAUzD,GAE9H,MAAOrD,GAAiB,SAAU2C,GAE9B4C,EAAoBF,YAAcE,EAAoBwB,WAAaxB,EAAsB7F,EAAiBmG,KAAKN,GAE/G,IAAIH,GAAyBG,EACxBO,cAAc,SAASjE,GAEpB,GAAImF,GAAenF,EAAQkF,SAASF,EAAWC,EAAUzD,GACrD0C,EAAkB7F,EAAkB8G,EAExC,OAAOhH,GAAiB,SAASgG,GAC7B,MAAO,IAAIvF,GAEP,GAAI0E,GAAuBtD,EAASkE,GACpCA,EAAgBhB,UAAUiB,EAAcpD,OAAOR,KAAK4D,GAAgBA,EAAc9C,QAAQd,KAAK4D,QAM/G,OAAOZ,GAAuBL,UAAUpC,KACzCsD,UAAUC,YAGjBtG,EAAeqH,iBAAmBvH,EAAiBuH,iBAAmB,SAAUpF,EAASgF,EAAWxD,GAEhG,MAAO,YAEH,IAAK,GADDoC,IAAQoB,GAAYR,EAAMC,UAAUC,OAC/BC,EAAI,EAAOH,EAAJG,IAAWA,EAAGf,EAAKgB,KAAKH,UAAUE,GAElD,OADAnD,IAAWoC,EAAKgB,KAAKpD,GACdnD,EAAkB2B,EAAQxC,KAAKsH,MAAM9E,EAAS4D,KAO7D,IAAIxB,GAAgBhF,EAAGgF,cAAgB,SAAUW,GAG7C,QAASX,GAAcpC,EAASkC,EAAOV,EAASW,GAC5C,GAAIM,GAAO/F,IACXA,MAAK2I,iBAAmB,GAAIjI,GAAGuB,QAC/BjC,KAAK4I,cAAgB,GAAIlI,GAAGuB,QAC5BjC,KAAK6I,WAAa1H,EAAiB4F,sBAAsBzD,EAASkC,EAAOV,EAAS9E,KAAK4I,eACvF5I,KAAKuG,SAAW7F,EAAGoB,SAASJ,OAAO,SAASuE,GACxC9E,EAAiByG,oBAAoBtE,EAASkC,EAAOS,EAAMiB,MAAQjB,EAAMoB,MAAOpB,EAAMkB,OAAQlB,EAAMnB,SAC/FgE,iBAAiB/C,EAAK4C,iBAAiBtE,OAAOR,KAAKkC,EAAK4C,qBAGjEI,OAAOC,eAAejD,EAAM,UAAWkD,IAAM,WACzC,MAAOlD,GAAK4C,iBAAiBO,kBAGjCH,OAAOC,eAAejD,EAAM,UAAWkD,IAAM,WACzC,MAAOlD,GAAK6C,cAAcM,mBAG1BzD,GAAyC,kBAAjBA,IAAuD,gBAAjBA,IAC9DzF,KAAKmJ,OAAO3C,UAAUf,GAE1BY,EAAUvF,KAAKd,KAAMA,KAAK6I,WAAWrC,UAAU3C,KAAK7D,KAAK6I,aAe7D,MAtCAnI,GAAGwF,UAAUS,SAASjB,EAAeW,GA0BrC3F,EAAGwF,UAAUC,cAAcT,EAAcnD,UAAW7B,EAAGoB,UACnD8C,YAAc,WACV5E,KAAKuG,SAAS3B,eAElBD,QAAS,SAASyE,GACdpJ,KAAKuG,SAAS5B,QAAQyE,IAE1B/E,OAAQ,SAAS4B,GACbjG,KAAKuG,SAASlC,OAAO4B,MAItBP,GACRhF,EAAGU,YAOFiI,EAAa,WAEb,QAASA,GAAWrC,GAEhB,GAAI6B,GAAa7B,CACbA,GAAoBP,YACpBoC,EAAa1H,EAAiBmG,KAAKN,GAC5B3E,EAAU2E,KACjB6B,EAAalH,EAAkBqF,IAGnChH,KAAK6I,WAAaA,EAClB7I,KAAKoD,WAAa,GAAI1C,GAAGwB,oBAkB7B,MAfAmH,GAAW9G,UAAUwB,QAAU,WAC3B/D,KAAKoD,WAAWW,WAGpBsF,EAAW9G,UAAU+G,GAAK,SAAS9D,EAAOV,EAASyE,EAAkB5E,EAASC,GAC1E,GAAIkB,GAAezE,EACd0F,sBAAsB/G,KAAK6I,WAAYrD,EAAOV,GAC9C0B,UAAU+C,EAAkB5E,EAASC,EAI1C,OAFA5E,MAAKoD,WAAWoG,IAAI1D,GAEb9F,MAIJqJ,IAOP,OAHJhI,GAAeuE,WAAazE,EAAiByE,WAAa,SAASoB,GAC/D,MAAO,IAAIqC,GAAWrC,IAEftG"}