{"version":3,"sources":["jsdelivr-header.js","/npm/@sachinraja/trpc-client@10.0.0-fetch.0/dist/index.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACNA,aAEA,OAAO,eAAe,QAAS,aAAc,CAAE,OAAO,IAEtD,IAAI,gBAAkB,QAAQ,yCAC1B,aAAe,QAAQ,sCACvB,WAAa,QAAQ,2BACrB,gBAAkB,QAAQ,yCAC1B,uBAAyB,QAAQ,gDACjC,UAAY,QAAQ,mCACpB,2BAA6B,QAAQ,oDACrC,gBAAkB,QAAQ,yCAC1B,iBAAmB,QAAQ,0CAC3B,eAAiB,QAAQ,wCAE7B,SAAS,sBAAuB,GAAK,OAAO,GAAkB,iBAAN,GAAkB,YAAa,EAAI,EAAI,CAAE,QAAW,EAAK,CAEjH,IAAI,yBAAwC,sBAAsB,iBAC9D,sBAAqC,sBAAsB,cAC3D,yBAAwC,sBAAsB,iBAC9D,gCAA+C,sBAAsB,wBACrE,mBAAkC,sBAAsB,WACxD,oCAAmD,sBAAsB,4BACzE,yBAAwC,sBAAsB,iBAC9D,0BAAyC,sBAAsB,kBAC/D,wBAAuC,sBAAsB,gBAEjE,SAAS,UAAU,EAAQ,GAAkB,IAAI,EAAO,OAAO,KAAK,GAAS,GAAI,OAAO,sBAAuB,CAAE,IAAI,EAAU,OAAO,sBAAsB,GAAS,IAAmB,EAAU,EAAQ,QAAO,SAAU,GAAO,OAAO,OAAO,yBAAyB,EAAQ,GAAK,UAAY,KAAK,EAAK,KAAK,MAAM,EAAM,EAAU,CAAE,OAAO,CAAM,CAEtV,SAAS,gBAAgB,GAAU,IAAK,IAAI,EAAI,EAAG,EAAI,UAAU,OAAQ,IAAK,CAAE,IAAI,EAAS,MAAQ,UAAU,GAAK,UAAU,GAAK,CAAC,EAAG,EAAI,EAAI,UAAU,OAAO,IAAS,GAAI,SAAQ,SAAU,GAAO,yBAAkC,QAAE,EAAQ,EAAK,EAAO,GAAO,IAAK,OAAO,0BAA4B,OAAO,iBAAiB,EAAQ,OAAO,0BAA0B,IAAW,UAAU,OAAO,IAAS,SAAQ,SAAU,GAAO,OAAO,eAAe,EAAQ,EAAK,OAAO,yBAAyB,EAAQ,GAAO,GAAI,CAAE,OAAO,CAAQ,CAEnhB,SAAS,eAAe,GAAW,IAAI,EAA4B,8BAA+B,OAAO,WAAkC,IAA0D,EAAtD,EAAQ,yBAAkC,QAAE,GAAkB,GAAI,EAA2B,CAAE,IAAI,EAAY,yBAAkC,QAAE,MAAM,YAAa,EAAS,QAAQ,UAAU,EAAO,UAAW,EAAY,MAAS,EAAS,EAAM,MAAM,KAAM,WAAc,OAAO,oCAA6C,QAAE,KAAM,EAAS,CAAG,CAExe,SAAS,8BAAgC,GAAuB,oBAAZ,UAA4B,QAAQ,UAAW,OAAO,EAAO,GAAI,QAAQ,UAAU,KAAM,OAAO,EAAO,GAAqB,mBAAV,MAAsB,OAAO,EAAM,IAAsF,OAAhF,QAAQ,UAAU,QAAQ,KAAK,QAAQ,UAAU,QAAS,IAAI,WAAa,MAAY,CAAM,CAAE,MAAO,GAAK,OAAO,CAAO,CAAE,CAE1U,IAAI,gBAA+B,SAAU,GAC3C,mBAA4B,QAAE,EAAiB,GAE/C,IAAI,EAAsB,eAAe,GAEzC,SAAS,EAAgB,EAAS,GAChC,IAAI,EAAc,EAEd,EAEJ,yBAAkC,QAAE,KAAM,GAE1C,IAAI,EAAQ,aAAmC,EAAS,EAAK,MAgB7D,OAbA,EAAQ,EAAO,KAAK,KAAM,EAAS,CACjC,MAAO,KAEH,WAAQ,EACd,EAAM,WAAQ,EACd,EAAM,UAAO,EACb,EAAM,UAAO,EACb,EAAM,KAAO,aAAmC,EAAS,EAAK,KAC9D,EAAM,MAAQ,EACd,EAAM,MAAQ,SAA6E,QAAhC,EAAe,EAAK,cAAqC,IAAjB,OAAlD,EAAqF,EAAa,MACnJ,EAAM,KAAO,SAA8E,QAAjC,EAAgB,EAAK,cAAsC,IAAlB,OAAnD,EAAuF,EAAc,MAAM,KAC3J,EAAM,KAAO,kBACb,OAAO,eAAe,gCAAyC,QAAE,GAAQ,EAAgB,WAClF,CACT,CA2BA,OAzBA,sBAA+B,QAAE,EAAiB,KAAM,CAAC,CACvD,IAAK,OACL,MAAO,SAAc,GACnB,IAGM,EAHF,EAAO,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,CAAC,EAEhF,OAAM,aAAiB,MASJ,oBAAf,EAAM,KACD,EAGF,IAAI,EAAgB,EAAM,QAAS,gBAAgB,gBAAgB,CAAC,EAAG,GAAO,CAAC,EAAG,CACvF,MAAO,EACP,OAAQ,QAZD,IAAI,EAAqD,QAApC,EAAW,EAAM,MAAM,eAAkC,IAAb,EAAsB,EAAW,GAAI,gBAAgB,gBAAgB,CAAC,EAAG,GAAO,CAAC,EAAG,CAC1J,MAAO,KACP,OAAQ,IAYd,KAGK,CACT,CAzDmC,CAyDnB,0BAAmC,QAAE,QAErD,SAAS,YACP,MAAsB,oBAAX,OACF,OAGF,MACT,CACA,SAAS,mBAAmB,GAC1B,IAAI,EAAM,YACV,OAAO,GAAM,EAAI,iBAAmB,IACtC,CAEA,SAAS,SAAS,GAChB,GAAI,EACF,OAAO,EAGT,IAAI,EAAM,YAEV,GAAI,EAAI,MACN,MAAiC,mBAAnB,EAAI,MAAM,KAAsB,EAAI,MAAM,KAAK,GAAO,EAAI,MAG1E,MAAM,IAAI,MAAM,gCAClB,CAEA,SAAS,aAEP,OAAO,WAEL,IAAI,EAAU,CAAC,EACf,OAAO,SAAU,GACf,IAAI,EAAK,EAAK,GACV,EAAO,EAAK,KAGhB,GAAgB,UAAZ,EAAG,KAEL,OAAO,EAAK,GAGd,IAAI,EAAM,KAAK,UAAU,CAAC,EAAG,KAAM,EAAG,QAEtC,GAAI,EAAQ,GAEV,OAAO,WAAW,YAAW,SAAU,GACrC,OAAO,EAAQ,GAAK,UAAU,EAChC,IAGF,IAAI,EAAU,WAAW,YAAW,SAAU,GAC5C,SAAS,WACA,EAAQ,EACjB,CAEA,IAAI,EAAe,EAAK,GAAI,UAAU,CACpC,KAAM,SAAc,GAClB,EAAS,KAAK,EAChB,EACA,MAAO,SAAe,GACpB,IACA,EAAS,MAAM,EACjB,EACA,SAAU,WACR,IACA,EAAS,UACX,IAEF,OAAO,WACL,IACA,EAAa,aACf,CACF,IAAG,KAAK,WAAW,SAEnB,OADA,EAAQ,GAAO,EACR,CACT,CACF,CACF,CAEA,SAAS,2BAA2B,EAAG,GAAkB,IAAI,EAAuB,oBAAX,QAA0B,EAAE,OAAO,WAAa,EAAE,cAAe,IAAK,EAAI,CAAE,GAAI,MAAM,QAAQ,KAAO,EAAK,4BAA4B,KAAO,GAAkB,GAAyB,iBAAb,EAAE,OAAqB,CAAM,IAAI,EAAI,GAAI,IAAI,EAAI,EAAO,EAAI,WAAc,EAAG,MAAO,CAAE,EAAG,EAAG,EAAG,WAAe,OAAI,GAAK,EAAE,OAAe,CAAE,MAAM,GAAe,CAAE,MAAM,EAAO,MAAO,EAAE,KAAQ,EAAG,EAAG,SAAW,GAAM,MAAM,CAAI,EAAG,EAAG,EAAK,CAAE,MAAM,IAAI,UAAU,wIAA0I,CAAE,IAA6C,EAAzC,GAAmB,EAAM,GAAS,EAAY,MAAO,CAAE,EAAG,WAAe,EAAK,EAAG,KAAK,EAAI,EAAG,EAAG,WAAe,IAAI,EAAO,EAAG,OAAsC,OAA9B,EAAmB,EAAK,KAAa,CAAM,EAAG,EAAG,SAAW,GAAO,GAAS,EAAM,EAAM,CAAK,EAAG,EAAG,WAAe,IAAW,GAAiC,MAAb,EAAG,QAAgB,EAAG,QAAU,CAAE,QAAU,GAAI,EAAQ,MAAM,CAAK,CAAE,EAAK,CAEr+B,SAAS,4BAA4B,EAAG,GAAU,GAAK,EAAL,CAAgB,GAAiB,iBAAN,EAAgB,OAAO,kBAAkB,EAAG,GAAS,IAAI,EAAI,OAAO,UAAU,SAAS,KAAK,GAAG,MAAM,GAAI,GAAiE,MAAnD,WAAN,GAAkB,EAAE,cAAa,EAAI,EAAE,YAAY,MAAgB,QAAN,GAAqB,QAAN,EAAoB,MAAM,KAAK,GAAc,cAAN,GAAqB,2CAA2C,KAAK,GAAW,kBAAkB,EAAG,QAAzG,CAA7O,CAA+V,CAE/Z,SAAS,kBAAkB,EAAK,IAAkB,MAAP,GAAe,EAAM,EAAI,UAAQ,EAAM,EAAI,QAAQ,IAAK,IAAI,EAAI,EAAG,EAAO,IAAI,MAAM,GAAM,EAAI,EAAK,IAAO,EAAK,GAAK,EAAI,GAAM,OAAO,CAAM,CAOtL,IAAI,gBAAkB,WACpB,MAAM,IAAI,MAAM,0FAClB,EAQA,SAAS,WAAW,GAClB,IAAI,EAAe,KACf,EAAgB,KAwDpB,SAAS,IACP,IAAI,EA7CN,SAAoB,GAIlB,IAHA,IAAI,EAAe,CAAC,IAChB,EAAQ,IAEC,CACX,IAAI,EAAO,EAAM,GAEjB,IAAK,EAEH,MAGF,IAAI,EAAY,EAAa,EAAa,OAAS,GAE/C,EAAK,SAEP,EAAK,OAAO,IAAI,MAAM,YACtB,KAIY,EAAY,SAAS,EAAU,OAAO,GAAM,KAAI,SAAU,GACtE,OAAO,EAAG,GACZ,MAGE,EAAU,KAAK,GACf,KAIuB,IAArB,EAAU,OAOd,EAAa,KAAK,KANhB,EAAK,OAAO,IAAI,MAAM,2CACtB,IAMJ,CAEA,OAAO,CACT,CAGqB,CAAW,GAtD9B,aAAa,GACb,EAAgB,KAChB,EAAe,KAuDf,IACI,EADA,EAAY,2BAA2B,GAG3C,IACE,IAAI,EAAQ,WACV,IAAI,EAAQ,EAAM,MAElB,IAAK,EAAM,OACT,MAAO,WAGT,IAMI,EANA,EAAQ,CACV,MAAO,EACP,OAAQ,iBAGN,EAAa,2BAA2B,GAG5C,IACE,IAAK,EAAW,MAAO,EAAS,EAAW,KAAK,MAAO,CAC1C,EAAO,MACb,MAAQ,CACf,CACF,CAAE,MAAO,GACP,EAAW,EAAE,EACf,CAAE,QACA,EAAW,GACb,CAEA,IAAI,EAAqB,EAAY,MAAM,EAAM,MAAM,KAAI,SAAU,GACnE,OAAO,EAAM,GACf,KACI,EAAU,EAAmB,QAC7B,EAAS,EAAmB,OAEhC,EAAM,OAAS,EACf,EAAQ,MAAK,SAAU,GACrB,IAAK,IAAI,EAAI,EAAG,EAAI,EAAO,OAAQ,IAAK,CACtC,IAAI,EAAS,EAAO,GAChB,EAAO,EAAM,MAAM,GACvB,EAAK,QAAQ,GACb,EAAK,MAAQ,IACf,CACF,IAAG,OAAM,SAAU,GACjB,IACI,EADA,EAAa,2BAA2B,EAAM,OAGlD,IACE,IAAK,EAAW,MAAO,EAAS,EAAW,KAAK,MAAO,CACrD,IAAI,EAAO,EAAO,MAClB,EAAK,OAAO,GACZ,EAAK,MAAQ,IACf,CACF,CAAE,MAAO,GACP,EAAW,EAAE,EACf,CAAE,QACA,EAAW,GACb,CACF,GACF,EAEA,IAAK,EAAU,MAAO,EAAQ,EAAU,KAAK,MAChC,GAIf,CAAE,MAAO,GACP,EAAU,EAAE,EACd,CAAE,QACA,EAAU,GACZ,CACF,CA6CA,MAAO,CACL,KA5CF,SAAc,GACZ,IAAI,EAAO,CACT,SAAS,EACT,IAAK,EACL,MAAO,KACP,QAAS,gBACT,OAAQ,iBAEN,EAAU,IAAI,SAAQ,SAAU,EAAS,GAC3C,EAAK,OAAS,EACd,EAAK,QAAU,EAEV,IACH,EAAe,IAGjB,EAAa,KAAK,EACpB,IAoBA,OAlBK,IACH,EAAgB,WAAW,IAiBtB,CACL,QAAS,EACT,OAhBW,WACX,IAAI,EAEJ,EAAK,SAAU,EAEoB,QAA9B,EAAc,EAAK,aAAmC,IAAhB,GAA0B,EAAY,MAAM,OAAM,SAAU,GACrG,OAAO,EAAK,OACd,MAEE,EAAK,MAAM,SACX,EAAK,MAAQ,KAEjB,EAMF,EAKF,CAEA,SAAS,UAAU,EAAQ,GAAkB,IAAI,EAAO,OAAO,KAAK,GAAS,GAAI,OAAO,sBAAuB,CAAE,IAAI,EAAU,OAAO,sBAAsB,GAAS,IAAmB,EAAU,EAAQ,QAAO,SAAU,GAAO,OAAO,OAAO,yBAAyB,EAAQ,GAAK,UAAY,KAAK,EAAK,KAAK,MAAM,EAAM,EAAU,CAAE,OAAO,CAAM,CAEtV,SAAS,gBAAgB,GAAU,IAAK,IAAI,EAAI,EAAG,EAAI,UAAU,OAAQ,IAAK,CAAE,IAAI,EAAS,MAAQ,UAAU,GAAK,UAAU,GAAK,CAAC,EAAG,EAAI,EAAI,UAAU,OAAO,IAAS,GAAI,SAAQ,SAAU,GAAO,yBAAkC,QAAE,EAAQ,EAAK,EAAO,GAAO,IAAK,OAAO,0BAA4B,OAAO,iBAAiB,EAAQ,OAAO,0BAA0B,IAAW,UAAU,OAAO,IAAS,SAAQ,SAAU,GAAO,OAAO,eAAe,EAAQ,EAAK,OAAO,yBAAyB,EAAQ,GAAO,GAAI,CAAE,OAAO,CAAQ,CAGnhB,SAAS,YAAY,GAGnB,IAFA,IAAI,EAAO,CAAC,EAEH,EAAQ,EAAG,EAAQ,EAAM,OAAQ,IAAS,CACjD,IAAI,EAAU,EAAM,GACpB,EAAK,GAAS,CAChB,CAEA,OAAO,CACT,CAEA,IAAI,OAAS,CACX,MAAO,MACP,SAAU,OACV,aAAc,SAGhB,SAAS,SAAS,GAChB,MAAO,UAAW,EAAO,EAAK,QAAQ,YAAY,UAAU,EAAK,OAAS,YAAY,EAAK,OAAO,KAAI,SAAU,GAC9G,OAAO,EAAK,QAAQ,YAAY,UAAU,EAC5C,IACF,CAEA,SAAS,OAAO,GACd,IAAI,EAAM,EAAK,IAAM,IAAM,EAAK,KAC5B,EAAa,GAMjB,GAJI,WAAY,GACd,EAAW,KAAK,WAGA,UAAd,EAAK,KAAkB,CACzB,IAAI,EAAQ,SAAS,QAEP,IAAV,GACF,EAAW,KAAK,SAAS,OAAO,mBAAmB,KAAK,UAAU,KAEtE,CAMA,OAJI,EAAW,SACb,GAAO,IAAM,EAAW,KAAK,MAGxB,CACT,CACA,SAAS,QAAQ,GACf,GAAkB,UAAd,EAAK,KAAT,CAIA,IAAI,EAAQ,SAAS,GACrB,YAAiB,IAAV,EAAsB,KAAK,UAAU,QAAS,CAHrD,CAIF,CACA,SAAS,YAAY,GACnB,IAAI,EAAO,EAAK,KACZ,EAAU,EAAK,QACf,EAAK,EAAQ,gBAAkB,IAAI,EAAQ,gBAAoB,KA6BnE,MAAO,CACL,QA7BY,IAAI,SAAQ,SAAU,EAAS,GAC3C,IAAI,EAAM,OAAO,GACb,EAAO,QAAQ,GACf,EAAO,CAAC,EACZ,QAAQ,QAAQ,EAAQ,WAAW,MAAK,SAAU,GAChD,OAAO,EAAQ,MAAM,EAAK,CACxB,OAAQ,OAAO,GACf,OAAQ,aAA+B,EAAS,EAAG,OACnD,KAAM,EACN,QAAS,gBAAgB,CACvB,eAAgB,oBACf,IAEP,IAAG,MAAK,SAAU,GAEhB,OADA,EAAK,SAAW,EACT,EAAK,MACd,IAAG,MAAK,SAAU,GAChB,EAAQ,CACN,KAAM,EACN,KAAM,GAEV,IAAG,MAAM,EACX,IAQE,OANW,WACX,SAAwC,EAAG,OAC7C,EAMF,CAEA,SAAS,cAAc,GAErB,OAAO,SAAU,GACf,IAAI,EAAe,EAAK,cAAgB,IAEpC,EAAc,SAAqB,GA0DrC,MAAO,CACL,SA1Da,SAAkB,GAC/B,GAAI,IAAiB,IAEnB,OAAO,EAGT,IAAI,EAAO,EAAS,KAAI,SAAU,GAChC,OAAO,EAAG,IACZ,IAAG,KAAK,KACJ,EAAS,EAAS,KAAI,SAAU,GAClC,OAAO,EAAG,KACZ,IAQA,OAPU,OAAO,CACf,IAAK,EAAK,IACV,QAAS,EACT,KAAM,EACN,KAAM,EACN,OAAQ,IAEC,QAAU,CACvB,EAuCE,MArCU,SAAe,GACzB,IAAI,EAAO,EAAS,KAAI,SAAU,GAChC,OAAO,EAAG,IACZ,IAAG,KAAK,KACJ,EAAS,EAAS,KAAI,SAAU,GAClC,OAAO,EAAG,KACZ,IAEI,EAAe,YAAY,CAC7B,IAAK,EAAK,IACV,QAAS,EACT,KAAM,EACN,KAAM,EACN,OAAQ,IAEN,EAAU,EAAa,QACvB,EAAS,EAAa,OAE1B,MAAO,CACL,QAAS,EAAQ,MAAK,SAAU,GAU9B,OATc,MAAM,QAAQ,EAAI,MAAQ,EAAI,KAAO,EAAS,KAAI,WAC9D,OAAO,EAAI,IACb,KACqB,KAAI,SAAU,GACjC,MAAO,CACL,KAAM,EAAI,KACV,KAAM,EAEV,GAEF,IACA,OAAQ,EAEZ,EAMF,EAEI,EAAQ,WAAW,EAAY,UAC/B,EAAW,WAAW,EAAY,aAElC,EAAU,CACZ,MAAO,EACP,aAHiB,WAAW,EAAY,iBAIxC,SAAU,GAEZ,OAAO,SAAU,GACf,IAAI,EAAK,EAAK,GACd,OAAO,WAAW,YAAW,SAAU,GACrC,IAEI,EAFS,EAAQ,EAAG,MAEE,KAAK,GAC3B,EAAU,EAAa,QACvB,EAAS,EAAa,OAW1B,OATA,EAAQ,MAAK,SAAU,GACrB,EAAS,KAAK,CACZ,QAAS,EAAI,KACb,KAAM,EAAI,OAEZ,EAAS,UACX,IAAG,OAAM,SAAU,GACjB,OAAO,EAAS,MAAM,EACxB,IACO,WACL,GACF,CACF,GACF,CACF,CACF,CAEA,SAAS,SAAS,GAChB,IAAI,EAAM,EAAK,IACf,OAAO,SAAU,GACf,OAAO,SAAU,GACf,IAAI,EAAK,EAAK,GACd,OAAO,WAAW,YAAW,SAAU,GACrC,IAAI,EAAO,EAAG,KACV,EAAQ,EAAG,MACX,EAAO,EAAG,KAEV,EAAe,YAAY,CAC7B,IAAK,EACL,QAAS,EACT,KAAM,EACN,KAAM,EACN,MAAO,IAEL,EAAU,EAAa,QACvB,EAAS,EAAa,OAS1B,OAPA,EAAQ,MAAK,SAAU,GACrB,EAAS,KAAK,CACZ,QAAS,EAAI,KACb,KAAM,EAAI,OAEZ,EAAS,UACX,IAAG,MAAM,EAAS,OACX,WACL,GACF,CACF,GACF,CACF,CACF,CAEA,SAAS,UAAU,EAAQ,GAAkB,IAAI,EAAO,OAAO,KAAK,GAAS,GAAI,OAAO,sBAAuB,CAAE,IAAI,EAAU,OAAO,sBAAsB,GAAS,IAAmB,EAAU,EAAQ,QAAO,SAAU,GAAO,OAAO,OAAO,yBAAyB,EAAQ,GAAK,UAAY,KAAK,EAAK,KAAK,MAAM,EAAM,EAAU,CAAE,OAAO,CAAM,CAEtV,SAAS,gBAAgB,GAAU,IAAK,IAAI,EAAI,EAAG,EAAI,UAAU,OAAQ,IAAK,CAAE,IAAI,EAAS,MAAQ,UAAU,GAAK,UAAU,GAAK,CAAC,EAAG,EAAI,EAAI,UAAU,OAAO,IAAS,GAAI,SAAQ,SAAU,GAAO,yBAAkC,QAAE,EAAQ,EAAK,EAAO,GAAO,IAAK,OAAO,0BAA4B,OAAO,iBAAiB,EAAQ,OAAO,0BAA0B,IAAW,UAAU,OAAO,IAAS,SAAQ,SAAU,GAAO,OAAO,eAAe,EAAQ,EAAK,OAAO,yBAAyB,EAAQ,GAAO,GAAI,CAAE,OAAO,CAAQ,CACnhB,IAAI,QAAU,CACZ,MAAO,CAAC,SAAU,UAClB,SAAU,CAAC,SAAU,UACrB,aAAc,CAAC,SAAU,WAIvB,cAAgB,WAClB,IAAI,EAAI,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,QAC5E,OAAO,SAAU,GACf,IAAI,EAAY,EAAM,UAClB,EAAQ,EAAM,MACd,EAAO,EAAM,KACb,EAAO,EAAM,KACb,EAAU,EAAM,QAChB,EAAK,EAAM,GAEX,EAAgB,wBAAiC,QAAE,QAAQ,GAAO,GAClE,EAAQ,EAAc,GACtB,EAAO,EAAc,GAErB,EAAM,4BAA4B,OAAqB,OAAd,EAAqB,EAAQ,EAAM,mBAAmB,OAAqB,OAAd,EAAqB,QAAU,QAAS,4BAC9I,EAAQ,CAAC,KAAoB,OAAd,EAAqB,KAAO,KAAM,EAAM,IAAI,OAAO,GAAK,KAAK,OAAO,EAAM,MAAO,MAChG,EAAO,CAAC,EAAK,GAAG,OAAO,EAAK,wBAAyB,GAAG,OAAO,EAAK,2BAEhD,OAApB,EAAM,UACR,EAAK,KAAK,CACR,MAAO,EACP,QAAS,IAGX,EAAK,KAAK,CACR,MAAO,EACP,OAAQ,EAAM,OACd,UAAW,EAAM,UACjB,QAAS,IAIb,IAAI,EAAyB,SAApB,EAAM,WAAwB,EAAM,SAAW,EAAM,kBAAkB,OAAS,UAAW,EAAM,OAAO,MAAQ,QAAU,MACnI,EAAE,GAAI,MAAM,KAAM,CAAC,EAAM,KAAK,MAAM,OAAO,GAC7C,CACF,EAEA,SAAS,aACP,IAAI,EAAO,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,CAAC,EAC5E,EAAgB,EAAK,QACrB,OAA4B,IAAlB,EAA2B,WACvC,OAAO,CACT,EAAI,EACA,EAAe,EAAK,OACpB,OAA0B,IAAjB,EAA0B,cAAc,EAAK,SAAW,EACrE,OAAO,WACL,OAAO,SAAU,GACf,IAAI,EAAK,EAAK,GACV,EAAO,EAAK,KAChB,OAAO,WAAW,YAAW,SAAU,GAErC,EAAQ,gBAAgB,gBAAgB,CAAC,EAAG,GAAK,CAAC,EAAG,CACnD,UAAW,SACN,EAAO,gBAAgB,gBAAgB,CAAC,EAAG,GAAK,CAAC,EAAG,CACzD,UAAW,QAEb,IAAI,EAAmB,KAAK,MAE5B,SAAS,EAAU,GACjB,IAAI,EAAY,KAAK,MAAQ,EAC7B,EAAQ,gBAAgB,gBAAgB,CAAC,EAAG,GAAK,CAAC,EAAG,CACnD,UAAW,OACX,OAAQ,MACH,EAAO,gBAAgB,gBAAgB,CAAC,EAAG,GAAK,CAAC,EAAG,CACzD,UAAW,OACX,UAAW,EACX,OAAQ,IAEZ,CAEA,OAAO,EAAK,GAAI,KAAK,WAAW,IAAI,CAClC,KAAM,SAAc,GAClB,EAAU,EACZ,EACA,MAAO,SAAe,GACpB,EAAU,EACZ,KACE,UAAU,EAChB,GACF,CACF,CACF,CAEA,SAAS,UAAU,GAEjB,OAAO,WAEL,OAAO,SAAU,GACf,IAAI,EAAK,EAAK,GACV,EAAO,EAAK,KAEhB,OAAO,WAAW,YAAW,SAAU,GACrC,IAAI,EAAQ,KACR,EAAW,EACX,GAAS,EAwCb,OAtCA,SAAS,IACP,IAAI,EAEJ,IACqB,QAApB,EAAS,SAA8B,IAAX,GAA6B,EAAO,cACjE,EAAQ,EAAK,GAAI,UAAU,CACzB,MAAO,SAAe,GAChB,GAAY,EAAK,SACnB,EAAS,MAAM,GAIjB,GACF,EACA,KAAM,SAAc,GAClB,MAAI,WAAY,EAAO,MAMnB,GAAY,EAAK,UALnB,GAAS,OACT,EAAS,KAAK,SAUhB,GACF,EACA,SAAU,WACJ,GACF,EAAS,UAEb,GAEJ,CAEA,GACO,WACL,IAAI,EAEJ,GAAS,EACa,QAArB,EAAU,SAA+B,IAAZ,GAA8B,EAAQ,aACtE,CACF,GACF,CACF,CACF,CAGA,SAAS,YAAY,GACnB,OAAO,WAAW,YAAW,SAAU,GAerC,IAAI,EAdJ,SAAS,IACP,IAAI,EAAQ,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,EAC5E,EAAK,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,EAAK,GASlF,OAPmB,EADR,EAAK,MAAM,IACE,CACtB,GAAI,EACJ,KAAM,SAAc,GAElB,OADmB,EAAQ,EAAQ,EAAG,EAExC,GAGJ,CAEW,GACX,OAAO,EAAK,UAAU,EACxB,GACF,CAEA,SAAS,QAAQ,GACf,OAAO,MAAM,QAAQ,GAAS,EAAQ,CAAC,EACzC,CAEA,SAAS,UAAU,GACjB,OAAO,SAAU,GACf,IAAI,EAAM,QAAQ,EAAK,MAAM,KAAI,SAAU,GACzC,OAAO,EAAK,EACd,IACI,EAAK,QAAQ,EAAK,OAAO,KAAI,SAAU,GACzC,OAAO,EAAK,EACd,IACA,OAAO,SAAU,GACf,OAAO,WAAW,YAAW,SAAU,GACrC,IAAI,EAAQ,EAAK,UAAU,EAAM,IAAM,EAAM,EAC7C,OAAO,YAAY,CACjB,GAAI,EAAM,GACV,MAAO,IACN,UAAU,EACf,GACF,CACF,CACF,CAGA,IAAI,WAAa,SAAoB,GACnC,OAAwB,IAAjB,EAAqB,EAAI,KAAK,IAAI,IAAO,KAAK,IAAI,EAAG,GAAe,IAC7E,EAEA,SAAS,aAAa,GAAW,IAAI,EAA4B,4BAA6B,OAAO,WAAkC,IAA0D,EAAtD,EAAQ,yBAAkC,QAAE,GAAkB,GAAI,EAA2B,CAAE,IAAI,EAAY,yBAAkC,QAAE,MAAM,YAAa,EAAS,QAAQ,UAAU,EAAO,UAAW,EAAY,MAAS,EAAS,EAAM,MAAM,KAAM,WAAc,OAAO,oCAA6C,QAAE,KAAM,EAAS,CAAG,CAEpe,SAAS,4BAA8B,GAAuB,oBAAZ,UAA4B,QAAQ,UAAW,OAAO,EAAO,GAAI,QAAQ,UAAU,KAAM,OAAO,EAAO,GAAqB,mBAAV,MAAsB,OAAO,EAAM,IAAsF,OAAhF,QAAQ,UAAU,QAAQ,KAAK,QAAQ,UAAU,QAAS,IAAI,WAAa,MAAY,CAAM,CAAE,MAAO,GAAK,OAAO,CAAO,CAAE,CACxU,SAAS,eAAe,GACtB,IAAI,EAAM,EAAK,IACX,EAAkB,EAAK,UACvB,OAAoC,IAApB,EAA6B,UAAY,EACzD,EAAqB,EAAK,aAC1B,OAAsC,IAAvB,EAAgC,WAAa,EAGhE,IAAK,EACH,MAAM,IAAI,MAAM,gJAOlB,IAAI,EAAW,GAKX,EAAkB,OAAO,OAAO,MAChC,EAAiB,EACjB,EAAgB,KAChB,EAAe,KACf,EAAmB,IACnB,EAAQ,aAKZ,SAAS,IACO,SAAV,GAAoB,IAIxB,EAAgB,YAAW,WACzB,EAAgB,KAEQ,IAApB,EAAS,OAEX,EAAiB,KAAK,KAAK,UAAU,EAAS,QAG9C,EAAiB,KAAK,KAAK,UAAU,IAIvC,EAAW,EACb,IACF,CAEA,SAAS,IACH,GAA0B,WAAV,GAetB,SAAuB,GACrB,GAAI,EACF,OAGF,EAAQ,aACR,EAAe,WAAW,EAAW,EACvC,CAjBE,CADc,EAAa,KAE7B,CAEA,SAAS,IACP,EAAQ,aACR,IAAI,EAAgB,EACpB,EAAmB,IACnB,EAAiB,EACnB,CAWA,SAAS,EAAiB,GAEC,OAAO,OAAO,GAAiB,MAAK,SAAU,GACrE,OAAO,EAAE,KAAO,CAClB,KAGE,EAAK,OAET,CAEA,SAAS,EAA8B,GACjC,EAAS,MAAK,SAAU,GAC1B,OAAO,EAAE,KAAO,EAAI,GAAG,EACzB,KAIA,EAAQ,EAAI,GAAI,EAAI,UACtB,CAEA,SAAS,IACP,IAAI,EAAO,IAAI,UAAU,GACzB,aAAa,GACb,EAAe,KACf,EAAK,iBAAiB,QAAQ,WAExB,IAAS,IAIb,EAAiB,EACjB,EAAQ,OACR,IACF,IACA,EAAK,iBAAiB,SAAS,WACzB,IAAS,GACX,GAEJ,IAqFA,OA3CA,EAAK,iBAAiB,WAAW,SAAU,GACzC,IAAI,EAAO,EAAK,KACZ,EAAM,KAAK,MAAM,GAEjB,WAAY,EA5CU,SAA+B,GACzD,GAAmB,cAAf,EAAI,QAA0B,IAAS,EAAkB,CAC3D,IAEA,IAAK,IAAI,EAAK,EAAG,EAAiB,OAAO,OAAO,GAAkB,EAAK,EAAe,OAAQ,IAAM,CAClG,IAAI,EAAa,EAAe,GAER,iBAApB,EAAW,MACb,EAA8B,EAElC,CACF,CACF,CAiCI,CAAsB,GA/BG,SAAgC,GAC3D,IAAI,EAAqB,EAErB,EAAkB,OAAZ,EAAK,IAAe,EAAgB,EAAK,IAEnD,GAAK,EAAL,CASA,GAJkE,QAAjE,GAAuB,EAAiB,EAAI,WAAW,YAA0C,IAAxB,GAA0C,EAAoB,KAAK,EAAgB,CAC3J,KAAM,IAGJ,EAAI,KAAO,GAAoB,IAAS,EAAkB,CAC5D,IAAI,EAAQ,EAAI,GAEhB,EAAI,GAAK,EACT,EAAiB,EACnB,CAEI,WAAY,GAA6B,YAArB,EAAK,OAAO,MAAsB,IAAS,GACjE,EAAI,UAAU,UAdhB,CAgBF,CASI,CAAuB,GAGrB,IAAS,GAA8B,WAAV,GAE/B,EAAiB,EAErB,IACA,EAAK,iBAAiB,SAAS,WAM7B,IAAK,IAAI,KALL,IAAqB,GAEvB,IAGc,EAAiB,CAC/B,IAAI,EAAsB,EAWpB,EAAuB,EATzB,EAAM,EAAgB,GAE1B,GAAI,EAAI,KAAO,EAMf,GAFqE,QAApE,GAAwB,EAAkB,EAAI,WAAW,aAA4C,IAAzB,GAA2C,EAAqB,KAAK,EAAiB,gBAAgB,KAAK,IAAI,yBAAyB,kCAEpM,iBAAb,EAAI,YAGC,EAAgB,GACkD,QAAxE,GAAyB,EAAkB,EAAI,WAAW,gBAAgD,IAA1B,GAA4C,EAAsB,KAAK,OACrI,WAAV,GAET,EAA8B,EAElC,CACF,IACO,CACT,CAEA,SAAS,EAAQ,EAAI,GACnB,IAAI,EAAO,EAAG,KACV,EAAQ,EAAG,MACX,EAAO,EAAG,KACV,EAAK,EAAG,GACR,EAAW,CACb,GAAI,EACJ,OAAQ,EACR,OAAQ,CACN,MAAO,EACP,KAAM,IAYV,OATA,EAAgB,GAAM,CACpB,GAAI,EACJ,KAAM,EACN,UAAW,EACX,GAAI,GAGN,EAAS,KAAK,GACd,IACO,WACL,IAAI,EAAqB,EAErB,EAA4D,QAA/C,EAAsB,EAAgB,UAAyC,IAAxB,OAAiC,EAAS,EAAoB,iBAC/H,EAAgB,GACvB,EAAW,EAAS,QAAO,SAAU,GACnC,OAAO,EAAI,KAAO,CACpB,IACA,SAAqG,QAA9C,EAAsB,EAAU,gBAA8C,IAAxB,GAA0C,EAAoB,KAAK,GAEhK,iBAAZ,EAAG,OACL,EAAS,KAAK,CACZ,GAAI,EACJ,OAAQ,sBAEV,IAEJ,CACF,CAEA,MAAO,CACL,MAAO,WACL,EAAQ,SACR,EAAiB,EACnB,EACA,QAAS,EACT,cAAe,WACb,OAAO,CACT,EAEJ,CAEA,IAAI,yBAAwC,SAAU,GACpD,mBAA4B,QAAE,EAA0B,GAExD,IAAI,EAAsB,aAAa,GAEvC,SAAS,EAAyB,GAChC,IAAI,EAOJ,OALA,yBAAkC,QAAE,KAAM,IAE1C,EAAQ,EAAO,KAAK,KAAM,IACpB,KAAO,2BACb,OAAO,eAAe,gCAAyC,QAAE,GAAQ,EAAyB,WAC3F,CACT,CAEA,OAAO,sBAA+B,QAAE,EAC1C,CAjB4C,CAiB5B,0BAAmC,QAAE,QAEjD,2BAA0C,SAAU,GACtD,mBAA4B,QAAE,EAA4B,GAE1D,IAAI,EAAuB,aAAa,GAExC,SAAS,EAA2B,GAClC,IAAI,EAOJ,OALA,yBAAkC,QAAE,KAAM,IAE1C,EAAS,EAAQ,KAAK,KAAM,IACrB,KAAO,6BACd,OAAO,eAAe,gCAAyC,QAAE,GAAS,EAA2B,WAC9F,CACT,CAEA,OAAO,sBAA+B,QAAE,EAC1C,CAjB8C,CAiB9B,0BAAmC,QAAE,QAErD,SAAS,OAAO,GACd,OAAO,SAAU,GACf,IAAI,EAAS,EAAK,OAClB,OAAO,SAAU,GACf,IAAI,EAAK,EAAM,GACf,OAAO,WAAW,YAAW,SAAU,GACrC,IAAI,EAAO,EAAG,KACV,EAAO,EAAG,KACV,EAAK,EAAG,GACR,EAAU,EAAG,QACb,EAAQ,EAAQ,YAAY,UAAU,EAAG,OACzC,GAAS,EACT,EAAQ,EAAO,QAAQ,CACzB,KAAM,EACN,KAAM,EACN,MAAO,EACP,GAAI,EACJ,QAAS,GACR,CACD,MAAO,SAAe,GACpB,GAAS,EACT,EAAS,MAAM,GACf,GACF,EACA,SAAU,WACH,EAIH,EAAS,YAHT,GAAS,EACT,EAAS,MAAM,gBAAgB,KAAK,IAAI,2BAA2B,iCAIvE,EACA,KAAM,SAAc,GAClB,EAAS,KAAK,GAEE,iBAAZ,EAAG,OAEL,GAAS,EACT,IACA,EAAS,WAEb,IAEF,OAAO,WACL,GAAS,EACT,GACF,CACF,GACF,CACF,CACF,CAEA,SAAS,QAAQ,EAAQ,GAAkB,IAAI,EAAO,OAAO,KAAK,GAAS,GAAI,OAAO,sBAAuB,CAAE,IAAI,EAAU,OAAO,sBAAsB,GAAS,IAAmB,EAAU,EAAQ,QAAO,SAAU,GAAO,OAAO,OAAO,yBAAyB,EAAQ,GAAK,UAAY,KAAK,EAAK,KAAK,MAAM,EAAM,EAAU,CAAE,OAAO,CAAM,CAEpV,SAAS,cAAc,GAAU,IAAK,IAAI,EAAI,EAAG,EAAI,UAAU,OAAQ,IAAK,CAAE,IAAI,EAAS,MAAQ,UAAU,GAAK,UAAU,GAAK,CAAC,EAAG,EAAI,EAAI,QAAQ,OAAO,IAAS,GAAI,SAAQ,SAAU,GAAO,yBAAkC,QAAE,EAAQ,EAAK,EAAO,GAAO,IAAK,OAAO,0BAA4B,OAAO,iBAAiB,EAAQ,OAAO,0BAA0B,IAAW,QAAQ,OAAO,IAAS,SAAQ,SAAU,GAAO,OAAO,eAAe,EAAQ,EAAK,OAAO,yBAAyB,EAAQ,GAAO,GAAI,CAAE,OAAO,CAAQ,CAG7gB,SAAS,yBAAyB,EAAQ,GACxC,IAAI,EAAU,EAAO,QAErB,MAAI,UAAW,EAAO,KAIb,CACL,IAAI,EACJ,MALU,gBAAgB,KAAK,cAAc,cAAc,CAAC,EAAG,EAAO,MAAO,CAAC,EAAG,CACjF,MAAO,EAAQ,YAAY,YAAY,EAAO,KAAK,UAKnD,QAAS,GAKN,CACL,IAAI,EACJ,KAHS,EAAQ,YAAY,YAAY,EAAO,KAAK,OAAO,MAI5D,QAAS,EAEb,CAGA,SAAS,qCAAqC,EAAQ,GACpD,IAAI,EAAU,EAAO,QAErB,MAAI,UAAW,EAAO,KAMb,CACL,IAAI,EACJ,MAPU,gBAAgB,KAAK,cAAc,cAAc,CAAC,EAAG,EAAO,MAAO,CAAC,EAAG,CACjF,MAAO,EAAQ,YAAY,YAAY,EAAO,KAAK,SACjD,CACF,KAAM,IAKN,QAAS,GAQN,CACL,IAAI,EACJ,KANS,cAAc,cAAc,CAAC,EAAG,EAAO,KAAK,QAAqC,SAA5B,EAAO,KAAK,OAAO,MAAmB,CACpG,KAAM,EAAQ,YAAY,YAAY,EAAO,KAAK,OAAO,QAMzD,QAAS,EAEb,CAEA,IAAI,UAAY,EAEhB,SAAS,eACP,QAAS,SACX,CAEA,IAAI,WAA0B,WAC5B,SAAS,EAAW,GAClB,IAAI,EAAQ,KAEZ,yBAAkC,QAAE,KAAM,GAE1C,KAAK,WAAQ,EACb,KAAK,aAAU,EAEf,IAAI,EAAS,SAAS,aAAmC,EAAS,EAAK,OAEnE,EAAK,mBAAmB,aAAmC,EAAS,EAAK,iBAe7E,IAAI,EAAc,EAAK,YAAc,UAAW,EAAK,YAAc,CACjE,UAAW,EAAK,YAAY,MAAM,UAClC,YAAa,EAAK,YAAY,OAAO,aACnC,EAAK,YAAc,CACrB,UAAW,SAAmB,GAC5B,OAAO,CACT,EACA,YAAa,SAAqB,GAChC,OAAO,CACT,GAEF,KAAK,QAAU,CACb,gBAAiB,EACjB,MAAO,EACP,QA3BF,WACE,GAAI,EAAK,QAAS,CAChB,IAAI,EAAU,EAAK,QACnB,MAA0B,mBAAZ,EAAyB,EAAU,WAC/C,OAAO,CACT,CACF,CAEA,OAAO,WACL,MAAO,CAAC,CACV,CACF,CAgBW,GACT,YAAa,GAIb,KAAK,MADH,UAAW,EACA,EAAK,MAAM,KAAI,SAAU,GACpC,OAAO,EAAK,EAAM,QACpB,IAEa,CAAC,cAAc,CAC1B,IAAK,EAAK,KADE,CAEX,KAAK,SAEZ,CAmHA,OAjHA,sBAA+B,QAAE,EAAY,CAAC,CAC5C,IAAK,WACL,MAAO,SAAkB,GACvB,IAAI,EAAO,EAAK,KACZ,EAAQ,EAAK,MACb,EAAO,EAAK,KACZ,EAAe,EAAK,QACpB,OAA2B,IAAjB,EAA0B,CAAC,EAAI,EAW7C,OAVa,YAAY,CACvB,MAAO,KAAK,MACZ,GAAI,CACF,GAAI,eACJ,KAAM,EACN,KAAM,EACN,MAAO,EACP,QAAS,KAGC,KAAK,WAAW,QAChC,GACC,CACD,IAAK,mBACL,MAAO,SAA0B,GAC/B,IAAI,EAAS,KAET,EAAO,KAAK,SAAS,GAErB,EAAuB,WAAW,oBAAoB,GACtD,EAAU,EAAqB,QAC/B,EAAQ,EAAqB,MAE7B,EAAqB,IAAI,SAAQ,SAAU,EAAS,GACtD,EAAQ,MAAK,SAAU,GACrB,IAAI,EAAc,yBAAyB,EAAQ,EAAO,SAEtD,EAAY,GACd,EAAQ,EAAY,MAItB,EAAO,EAAY,MACrB,IAAG,OAAM,SAAU,GACjB,EAAO,gBAAgB,KAAK,GAC9B,GACF,IAEA,OADA,EAAmB,OAAS,EACrB,CACT,GACC,CACD,IAAK,QACL,MAAO,SAAe,GACpB,IAAI,EAEA,EAAyE,QAA9D,EAAQ,UAAU,QAAU,OAAI,EAAY,UAAU,UAA0B,IAAV,OAAmB,EAAS,EAAM,QACvH,OAAO,KAAK,iBAAiB,CAC3B,KAAM,QACN,KAAM,EACN,MAAO,UAAU,QAAU,OAAI,EAAY,UAAU,GACrD,QAAS,GAEb,GACC,CACD,IAAK,WACL,MAAO,SAAkB,GACvB,IAAI,EAEA,EAAyE,QAA9D,EAAQ,UAAU,QAAU,OAAI,EAAY,UAAU,UAA0B,IAAV,OAAmB,EAAS,EAAM,QACvH,OAAO,KAAK,iBAAiB,CAC3B,KAAM,WACN,KAAM,EACN,MAAO,UAAU,QAAU,OAAI,EAAY,UAAU,GACrD,QAAS,GAEb,GACC,CACD,IAAK,eACL,MAAO,SAAsB,EAAM,EAAO,GACxC,IAAI,EAAc,KAAK,SAAS,CAC9B,KAAM,eACN,KAAM,EACN,MAAO,EACP,QAAS,EAAK,UAEZ,EAAU,KAAK,QACnB,OAAO,EAAY,UAAU,CAC3B,KAAM,SAAc,GAClB,IAAI,EAKE,EAHF,EAAc,qCAAqC,EAAQ,GAE3D,EAAY,GAGe,QAA5B,EAAa,EAAK,YAAiC,IAAf,GAAiC,EAAW,KAAK,EAAM,EAAY,MAI3E,QAA9B,EAAc,EAAK,aAAmC,IAAhB,GAAkC,EAAY,KAAK,EAAM,EAAY,MAC9G,EACA,MAAO,SAAe,GACpB,IAAI,EAE4B,QAA/B,EAAe,EAAK,aAAoC,IAAjB,GAAmC,EAAa,KAAK,EAAM,EACrG,EACA,SAAU,WACR,IAAI,EAEiC,QAApC,EAAiB,EAAK,gBAAyC,IAAnB,GAAqC,EAAe,KAAK,EACxG,GAEJ,KAGK,CACT,CAzK8B,GA4K9B,SAAS,iBAAiB,GACxB,OAAO,IAAI,WAAW,EACxB,CAEA,QAAQ,gBAAkB,gBAC1B,QAAQ,iBAAmB,iBAC3B,QAAQ,eAAiB,eACzB,QAAQ,WAAa,WACrB,QAAQ,SAAW,SACnB,QAAQ,cAAgB,cACxB,QAAQ,SAAW,SACnB,QAAQ,WAAa,WACrB,QAAQ,UAAY,UACpB,QAAQ,UAAY,UACpB,QAAQ,OAAS","file":"/npm/@sachinraja/trpc-client@10.0.0-fetch.0/dist/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/@sachinraja/trpc-client@10.0.0-fetch.0/dist/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","'use strict';\n\nObject.defineProperty(exports, '__esModule', { value: true });\n\nvar _classCallCheck = require('@babel/runtime/helpers/classCallCheck');\nvar _createClass = require('@babel/runtime/helpers/createClass');\nvar observable = require('@trpc/server/observable');\nvar _defineProperty = require('@babel/runtime/helpers/defineProperty');\nvar _assertThisInitialized = require('@babel/runtime/helpers/assertThisInitialized');\nvar _inherits = require('@babel/runtime/helpers/inherits');\nvar _possibleConstructorReturn = require('@babel/runtime/helpers/possibleConstructorReturn');\nvar _getPrototypeOf = require('@babel/runtime/helpers/getPrototypeOf');\nvar _wrapNativeSuper = require('@babel/runtime/helpers/wrapNativeSuper');\nvar _slicedToArray = require('@babel/runtime/helpers/slicedToArray');\n\nfunction _interopDefaultLegacy (e) { return e && typeof e === 'object' && 'default' in e ? e : { 'default': e }; }\n\nvar _classCallCheck__default = /*#__PURE__*/_interopDefaultLegacy(_classCallCheck);\nvar _createClass__default = /*#__PURE__*/_interopDefaultLegacy(_createClass);\nvar _defineProperty__default = /*#__PURE__*/_interopDefaultLegacy(_defineProperty);\nvar _assertThisInitialized__default = /*#__PURE__*/_interopDefaultLegacy(_assertThisInitialized);\nvar _inherits__default = /*#__PURE__*/_interopDefaultLegacy(_inherits);\nvar _possibleConstructorReturn__default = /*#__PURE__*/_interopDefaultLegacy(_possibleConstructorReturn);\nvar _getPrototypeOf__default = /*#__PURE__*/_interopDefaultLegacy(_getPrototypeOf);\nvar _wrapNativeSuper__default = /*#__PURE__*/_interopDefaultLegacy(_wrapNativeSuper);\nvar _slicedToArray__default = /*#__PURE__*/_interopDefaultLegacy(_slicedToArray);\n\nfunction ownKeys$3(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }\n\nfunction _objectSpread$3(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys$3(Object(source), !0).forEach(function (key) { _defineProperty__default[\"default\"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys$3(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }\n\nfunction _createSuper$1(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct$1(); return function _createSuperInternal() { var Super = _getPrototypeOf__default[\"default\"](Derived), result; if (hasNativeReflectConstruct) { var NewTarget = _getPrototypeOf__default[\"default\"](this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return _possibleConstructorReturn__default[\"default\"](this, result); }; }\n\nfunction _isNativeReflectConstruct$1() { if (typeof Reflect === \"undefined\" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === \"function\") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }\n\nvar TRPCClientError = /*#__PURE__*/function (_Error) {\n  _inherits__default[\"default\"](TRPCClientError, _Error);\n\n  var _super = /*#__PURE__*/_createSuper$1(TRPCClientError);\n\n  function TRPCClientError(message, opts) {\n    var _opts$result, _opts$result2;\n\n    var _this;\n\n    _classCallCheck__default[\"default\"](this, TRPCClientError);\n\n    var cause = opts === null || opts === void 0 ? void 0 : opts.cause; // eslint-disable-next-line @typescript-eslint/ban-ts-comment\n    // @ts-ignore https://github.com/tc39/proposal-error-cause\n\n    _this = _super.call(this, message, {\n      cause: cause\n    });\n    _this.cause = void 0;\n    _this.shape = void 0;\n    _this.data = void 0;\n    _this.meta = void 0;\n    _this.meta = opts === null || opts === void 0 ? void 0 : opts.meta;\n    _this.cause = cause;\n    _this.shape = opts === null || opts === void 0 ? void 0 : (_opts$result = opts.result) === null || _opts$result === void 0 ? void 0 : _opts$result.error;\n    _this.data = opts === null || opts === void 0 ? void 0 : (_opts$result2 = opts.result) === null || _opts$result2 === void 0 ? void 0 : _opts$result2.error.data;\n    _this.name = 'TRPCClientError';\n    Object.setPrototypeOf(_assertThisInitialized__default[\"default\"](_this), TRPCClientError.prototype);\n    return _this;\n  }\n\n  _createClass__default[\"default\"](TRPCClientError, null, [{\n    key: \"from\",\n    value: function from(cause) {\n      var opts = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};\n\n      if (!(cause instanceof Error)) {\n        var _message;\n\n        return new TRPCClientError((_message = cause.error.message) !== null && _message !== void 0 ? _message : '', _objectSpread$3(_objectSpread$3({}, opts), {}, {\n          cause: null,\n          result: cause\n        }));\n      }\n\n      if (cause.name === 'TRPCClientError') {\n        return cause;\n      }\n\n      return new TRPCClientError(cause.message, _objectSpread$3(_objectSpread$3({}, opts), {}, {\n        cause: cause,\n        result: null\n      }));\n    }\n  }]);\n\n  return TRPCClientError;\n}( /*#__PURE__*/_wrapNativeSuper__default[\"default\"](Error));\n\nfunction getWindow() {\n  if (typeof window !== 'undefined') {\n    return window;\n  }\n\n  return global;\n}\nfunction getAbortController(ac) {\n  var win = getWindow();\n  return ac || win.AbortController || null;\n}\n\nfunction getFetch(f) {\n  if (f) {\n    return f;\n  }\n\n  var win = getWindow();\n\n  if (win.fetch) {\n    return typeof win.fetch.bind === 'function' ? win.fetch.bind(win) : win.fetch;\n  }\n\n  throw new Error('No fetch implementation found');\n}\n\nfunction dedupeLink() {\n  // initialized config\n  return function () {\n    // initialized in app\n    var pending = {};\n    return function (_ref) {\n      var op = _ref.op,\n          next = _ref.next;\n\n      // initialized for request\n      if (op.type !== 'query') {\n        // pass through\n        return next(op);\n      }\n\n      var key = JSON.stringify([op.path, op.input]);\n\n      if (pending[key]) {\n        // console.log('hooking into pending', { op });\n        return observable.observable(function (observer) {\n          return pending[key].subscribe(observer);\n        });\n      }\n\n      var shared$ = observable.observable(function (observer) {\n        function reset() {\n          delete pending[key];\n        }\n\n        var subscription = next(op).subscribe({\n          next: function next(v) {\n            observer.next(v);\n          },\n          error: function error(e) {\n            reset();\n            observer.error(e);\n          },\n          complete: function complete() {\n            reset();\n            observer.complete();\n          }\n        });\n        return function () {\n          reset();\n          subscription.unsubscribe();\n        };\n      }).pipe(observable.share());\n      pending[key] = shared$;\n      return shared$;\n    };\n  };\n}\n\nfunction _createForOfIteratorHelper(o, allowArrayLike) { var it = typeof Symbol !== \"undefined\" && o[Symbol.iterator] || o[\"@@iterator\"]; if (!it) { if (Array.isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === \"number\") { if (it) o = it; var i = 0; var F = function F() {}; return { s: F, n: function n() { if (i >= o.length) return { done: true }; return { done: false, value: o[i++] }; }, e: function e(_e) { throw _e; }, f: F }; } throw new TypeError(\"Invalid attempt to iterate non-iterable instance.\\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.\"); } var normalCompletion = true, didErr = false, err; return { s: function s() { it = it.call(o); }, n: function n() { var step = it.next(); normalCompletion = step.done; return step; }, e: function e(_e2) { didErr = true; err = _e2; }, f: function f() { try { if (!normalCompletion && it.return != null) it.return(); } finally { if (didErr) throw err; } } }; }\n\nfunction _unsupportedIterableToArray(o, minLen) { if (!o) return; if (typeof o === \"string\") return _arrayLikeToArray(o, minLen); var n = Object.prototype.toString.call(o).slice(8, -1); if (n === \"Object\" && o.constructor) n = o.constructor.name; if (n === \"Map\" || n === \"Set\") return Array.from(o); if (n === \"Arguments\" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); }\n\nfunction _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) { arr2[i] = arr[i]; } return arr2; }\n\n/* eslint-disable @typescript-eslint/no-non-null-assertion */\n\n/**\n * A function that should never be called unless we messed something up.\n */\nvar throwFatalError = function throwFatalError() {\n  throw new Error('Something went wrong. Please submit an issue at https://github.com/trpc/trpc/issues/new');\n};\n/**\n * Dataloader that's very inspired by https://github.com/graphql/dataloader\n * Less configuration, no caching, and allows you to cancel requests\n * When cancelling a single fetch the whole batch will be cancelled only when _all_ items are cancelled\n */\n\n\nfunction dataLoader(batchLoader) {\n  var pendingItems = null;\n  var dispatchTimer = null;\n\n  var destroyTimerAndPendingItems = function destroyTimerAndPendingItems() {\n    clearTimeout(dispatchTimer);\n    dispatchTimer = null;\n    pendingItems = null;\n  };\n  /**\n   * Iterate through the items and split them into groups based on the `batchLoader`'s validate function\n   */\n\n\n  function groupItems(items) {\n    var groupedItems = [[]];\n    var index = 0;\n\n    while (true) {\n      var item = items[index];\n\n      if (!item) {\n        // we're done\n        break;\n      }\n\n      var lastGroup = groupedItems[groupedItems.length - 1];\n\n      if (item.aborted) {\n        // Item was aborted before it was dispatched\n        item.reject(new Error('Aborted'));\n        index++;\n        continue;\n      }\n\n      var isValid = batchLoader.validate(lastGroup.concat(item).map(function (it) {\n        return it.key;\n      }));\n\n      if (isValid) {\n        lastGroup.push(item);\n        index++;\n        continue;\n      }\n\n      if (lastGroup.length === 0) {\n        item.reject(new Error('Input is too big for a single dispatch'));\n        index++;\n        continue;\n      } // Create new group, next iteration will try to add the item to that\n\n\n      groupedItems.push([]);\n    }\n\n    return groupedItems;\n  }\n\n  function dispatch() {\n    var groupedItems = groupItems(pendingItems);\n    destroyTimerAndPendingItems(); // Create batches for each group of items\n\n    var _iterator = _createForOfIteratorHelper(groupedItems),\n        _step;\n\n    try {\n      var _loop = function _loop() {\n        var items = _step.value;\n\n        if (!items.length) {\n          return \"continue\";\n        }\n\n        var batch = {\n          items: items,\n          cancel: throwFatalError\n        };\n\n        var _iterator2 = _createForOfIteratorHelper(items),\n            _step2;\n\n        try {\n          for (_iterator2.s(); !(_step2 = _iterator2.n()).done;) {\n            var item = _step2.value;\n            item.batch = batch;\n          }\n        } catch (err) {\n          _iterator2.e(err);\n        } finally {\n          _iterator2.f();\n        }\n\n        var _batchLoader$fetch = batchLoader.fetch(batch.items.map(function (_item) {\n          return _item.key;\n        })),\n            promise = _batchLoader$fetch.promise,\n            cancel = _batchLoader$fetch.cancel;\n\n        batch.cancel = cancel;\n        promise.then(function (result) {\n          for (var i = 0; i < result.length; i++) {\n            var _value = result[i];\n            var item = batch.items[i];\n            item.resolve(_value);\n            item.batch = null;\n          }\n        }).catch(function (cause) {\n          var _iterator3 = _createForOfIteratorHelper(batch.items),\n              _step3;\n\n          try {\n            for (_iterator3.s(); !(_step3 = _iterator3.n()).done;) {\n              var item = _step3.value;\n              item.reject(cause);\n              item.batch = null;\n            }\n          } catch (err) {\n            _iterator3.e(err);\n          } finally {\n            _iterator3.f();\n          }\n        });\n      };\n\n      for (_iterator.s(); !(_step = _iterator.n()).done;) {\n        var _ret = _loop();\n\n        if (_ret === \"continue\") continue;\n      }\n    } catch (err) {\n      _iterator.e(err);\n    } finally {\n      _iterator.f();\n    }\n  }\n\n  function load(key) {\n    var item = {\n      aborted: false,\n      key: key,\n      batch: null,\n      resolve: throwFatalError,\n      reject: throwFatalError\n    };\n    var promise = new Promise(function (resolve, reject) {\n      item.reject = reject;\n      item.resolve = resolve;\n\n      if (!pendingItems) {\n        pendingItems = [];\n      }\n\n      pendingItems.push(item);\n    });\n\n    if (!dispatchTimer) {\n      dispatchTimer = setTimeout(dispatch);\n    }\n\n    var cancel = function cancel() {\n      var _item$batch;\n\n      item.aborted = true;\n\n      if ((_item$batch = item.batch) !== null && _item$batch !== void 0 && _item$batch.items.every(function (item) {\n        return item.aborted;\n      })) {\n        // All items in the batch have been cancelled\n        item.batch.cancel();\n        item.batch = null;\n      }\n    };\n\n    return {\n      promise: promise,\n      cancel: cancel\n    };\n  }\n\n  return {\n    load: load\n  };\n}\n\nfunction ownKeys$2(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }\n\nfunction _objectSpread$2(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys$2(Object(source), !0).forEach(function (key) { _defineProperty__default[\"default\"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys$2(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }\n\n// https://github.com/trpc/trpc/pull/669\nfunction arrayToDict(array) {\n  var dict = {};\n\n  for (var index = 0; index < array.length; index++) {\n    var element = array[index];\n    dict[index] = element;\n  }\n\n  return dict;\n}\n\nvar METHOD = {\n  query: 'GET',\n  mutation: 'POST',\n  subscription: 'PATCH'\n};\n\nfunction getInput(opts) {\n  return 'input' in opts ? opts.runtime.transformer.serialize(opts.input) : arrayToDict(opts.inputs.map(function (_input) {\n    return opts.runtime.transformer.serialize(_input);\n  }));\n}\n\nfunction getUrl(opts) {\n  var url = opts.url + '/' + opts.path;\n  var queryParts = [];\n\n  if ('inputs' in opts) {\n    queryParts.push('batch=1');\n  }\n\n  if (opts.type === 'query') {\n    var input = getInput(opts);\n\n    if (input !== undefined) {\n      queryParts.push(\"input=\".concat(encodeURIComponent(JSON.stringify(input))));\n    }\n  }\n\n  if (queryParts.length) {\n    url += '?' + queryParts.join('&');\n  }\n\n  return url;\n}\nfunction getBody(opts) {\n  if (opts.type === 'query') {\n    return undefined;\n  }\n\n  var input = getInput(opts);\n  return input !== undefined ? JSON.stringify(input) : undefined;\n}\nfunction httpRequest(opts) {\n  var type = opts.type,\n      runtime = opts.runtime;\n  var ac = runtime.AbortController ? new runtime.AbortController() : null;\n  var promise = new Promise(function (resolve, reject) {\n    var url = getUrl(opts);\n    var body = getBody(opts);\n    var meta = {};\n    Promise.resolve(runtime.headers()).then(function (headers) {\n      return runtime.fetch(url, {\n        method: METHOD[type],\n        signal: ac === null || ac === void 0 ? void 0 : ac.signal,\n        body: body,\n        headers: _objectSpread$2({\n          'content-type': 'application/json'\n        }, headers)\n      });\n    }).then(function (_res) {\n      meta.response = _res;\n      return _res.json();\n    }).then(function (json) {\n      resolve({\n        json: json,\n        meta: meta\n      });\n    }).catch(reject);\n  });\n\n  var cancel = function cancel() {\n    ac === null || ac === void 0 ? void 0 : ac.abort();\n  };\n\n  return {\n    promise: promise,\n    cancel: cancel\n  };\n}\n\nfunction httpBatchLink(opts) {\n  // initialized config\n  return function (runtime) {\n    var maxURLLength = opts.maxURLLength || Infinity;\n\n    var batchLoader = function batchLoader(type) {\n      var validate = function validate(batchOps) {\n        if (maxURLLength === Infinity) {\n          // escape hatch for quick calcs\n          return true;\n        }\n\n        var path = batchOps.map(function (op) {\n          return op.path;\n        }).join(',');\n        var inputs = batchOps.map(function (op) {\n          return op.input;\n        });\n        var url = getUrl({\n          url: opts.url,\n          runtime: runtime,\n          type: type,\n          path: path,\n          inputs: inputs\n        });\n        return url.length <= maxURLLength;\n      };\n\n      var fetch = function fetch(batchOps) {\n        var path = batchOps.map(function (op) {\n          return op.path;\n        }).join(',');\n        var inputs = batchOps.map(function (op) {\n          return op.input;\n        });\n\n        var _httpRequest = httpRequest({\n          url: opts.url,\n          runtime: runtime,\n          type: type,\n          path: path,\n          inputs: inputs\n        }),\n            promise = _httpRequest.promise,\n            cancel = _httpRequest.cancel;\n\n        return {\n          promise: promise.then(function (res) {\n            var resJSON = Array.isArray(res.json) ? res.json : batchOps.map(function () {\n              return res.json;\n            });\n            var result = resJSON.map(function (item) {\n              return {\n                meta: res.meta,\n                json: item\n              };\n            });\n            return result;\n          }),\n          cancel: cancel\n        };\n      };\n\n      return {\n        validate: validate,\n        fetch: fetch\n      };\n    };\n\n    var query = dataLoader(batchLoader('query'));\n    var mutation = dataLoader(batchLoader('mutation'));\n    var subscription = dataLoader(batchLoader('subscription'));\n    var loaders = {\n      query: query,\n      subscription: subscription,\n      mutation: mutation\n    };\n    return function (_ref) {\n      var op = _ref.op;\n      return observable.observable(function (observer) {\n        var loader = loaders[op.type];\n\n        var _loader$load = loader.load(op),\n            promise = _loader$load.promise,\n            cancel = _loader$load.cancel;\n\n        promise.then(function (res) {\n          observer.next({\n            context: res.meta,\n            data: res.json\n          });\n          observer.complete();\n        }).catch(function (err) {\n          return observer.error(err);\n        });\n        return function () {\n          cancel();\n        };\n      });\n    };\n  };\n}\n\nfunction httpLink(opts) {\n  var url = opts.url;\n  return function (runtime) {\n    return function (_ref) {\n      var op = _ref.op;\n      return observable.observable(function (observer) {\n        var path = op.path,\n            input = op.input,\n            type = op.type;\n\n        var _httpRequest = httpRequest({\n          url: url,\n          runtime: runtime,\n          type: type,\n          path: path,\n          input: input\n        }),\n            promise = _httpRequest.promise,\n            cancel = _httpRequest.cancel;\n\n        promise.then(function (res) {\n          observer.next({\n            context: res.meta,\n            data: res.json\n          });\n          observer.complete();\n        }).catch(observer.error);\n        return function () {\n          cancel();\n        };\n      });\n    };\n  };\n}\n\nfunction ownKeys$1(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }\n\nfunction _objectSpread$1(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys$1(Object(source), !0).forEach(function (key) { _defineProperty__default[\"default\"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys$1(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }\nvar palette = {\n  query: ['72e3ff', '3fb0d8'],\n  mutation: ['c5a3fc', '904dfc'],\n  subscription: ['ff49e1', 'd83fbe']\n};\n\n// maybe this should be moved to it's own package\nvar defaultLogger = function defaultLogger() {\n  var c = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : console;\n  return function (props) {\n    var direction = props.direction,\n        input = props.input,\n        type = props.type,\n        path = props.path,\n        context = props.context,\n        id = props.id;\n\n    var _palette$type = _slicedToArray__default[\"default\"](palette[type], 2),\n        light = _palette$type[0],\n        dark = _palette$type[1];\n\n    var css = \"\\n    background-color: #\".concat(direction === 'up' ? light : dark, \"; \\n    color: \").concat(direction === 'up' ? 'black' : 'white', \";\\n    padding: 2px;\\n  \");\n    var parts = ['%c', direction === 'up' ? '>>' : '<<', type, \"#\".concat(id), \"%c\".concat(path, \"%c\"), '%O'];\n    var args = [css, \"\".concat(css, \"; font-weight: bold;\"), \"\".concat(css, \"; font-weight: normal;\")];\n\n    if (props.direction === 'up') {\n      args.push({\n        input: input,\n        context: context\n      });\n    } else {\n      args.push({\n        input: input,\n        result: props.result,\n        elapsedMs: props.elapsedMs,\n        context: context\n      });\n    }\n\n    var fn = props.direction === 'down' && props.result && (props.result instanceof Error || 'error' in props.result.data) ? 'error' : 'log';\n    c[fn].apply(null, [parts.join(' ')].concat(args));\n  };\n};\n\nfunction loggerLink() {\n  var opts = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};\n  var _opts$enabled = opts.enabled,\n      enabled = _opts$enabled === void 0 ? function () {\n    return true;\n  } : _opts$enabled;\n  var _opts$logger = opts.logger,\n      logger = _opts$logger === void 0 ? defaultLogger(opts.console) : _opts$logger;\n  return function () {\n    return function (_ref) {\n      var op = _ref.op,\n          next = _ref.next;\n      return observable.observable(function (observer) {\n        // ->\n        enabled(_objectSpread$1(_objectSpread$1({}, op), {}, {\n          direction: 'up'\n        })) && logger(_objectSpread$1(_objectSpread$1({}, op), {}, {\n          direction: 'up'\n        }));\n        var requestStartTime = Date.now();\n\n        function logResult(result) {\n          var elapsedMs = Date.now() - requestStartTime;\n          enabled(_objectSpread$1(_objectSpread$1({}, op), {}, {\n            direction: 'down',\n            result: result\n          })) && logger(_objectSpread$1(_objectSpread$1({}, op), {}, {\n            direction: 'down',\n            elapsedMs: elapsedMs,\n            result: result\n          }));\n        }\n\n        return next(op).pipe(observable.tap({\n          next: function next(result) {\n            logResult(result);\n          },\n          error: function error(result) {\n            logResult(result);\n          }\n        })).subscribe(observer);\n      });\n    };\n  };\n}\n\nfunction retryLink(opts) {\n  // initialized config\n  return function () {\n    // initialized in app\n    return function (_ref) {\n      var op = _ref.op,\n          next = _ref.next;\n      // initialized for request\n      return observable.observable(function (observer) {\n        var next$ = null;\n        var attempts = 0;\n        var isDone = false;\n\n        function attempt() {\n          var _next$;\n\n          attempts++;\n          (_next$ = next$) === null || _next$ === void 0 ? void 0 : _next$.unsubscribe();\n          next$ = next(op).subscribe({\n            error: function error(_error) {\n              if (attempts >= opts.attempts) {\n                observer.error(_error);\n                return;\n              }\n\n              attempt();\n            },\n            next: function next(result) {\n              if ('result' in result.data) {\n                isDone = true;\n                observer.next(result);\n                return;\n              }\n\n              if (attempts >= opts.attempts) {\n                isDone = true;\n                observer.next(result);\n                return;\n              }\n\n              attempt();\n            },\n            complete: function complete() {\n              if (isDone) {\n                observer.complete();\n              }\n            }\n          });\n        }\n\n        attempt();\n        return function () {\n          var _next$2;\n\n          isDone = true;\n          (_next$2 = next$) === null || _next$2 === void 0 ? void 0 : _next$2.unsubscribe();\n        };\n      });\n    };\n  };\n}\n\n/** @internal */\nfunction createChain(opts) {\n  return observable.observable(function (observer) {\n    function execute() {\n      var index = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 0;\n      var op = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : opts.op;\n      var next = opts.links[index];\n      var subscription = next({\n        op: op,\n        next: function next(nextOp) {\n          var nextObserver = execute(index + 1, nextOp);\n          return nextObserver;\n        }\n      });\n      return subscription;\n    }\n\n    var obs$ = execute();\n    return obs$.subscribe(observer);\n  });\n}\n\nfunction asArray(value) {\n  return Array.isArray(value) ? value : [value];\n}\n\nfunction splitLink(opts) {\n  return function (runtime) {\n    var yes = asArray(opts.true).map(function (link) {\n      return link(runtime);\n    });\n    var no = asArray(opts.false).map(function (link) {\n      return link(runtime);\n    });\n    return function (props) {\n      return observable.observable(function (observer) {\n        var links = opts.condition(props.op) ? yes : no;\n        return createChain({\n          op: props.op,\n          links: links\n        }).subscribe(observer);\n      });\n    };\n  };\n}\n\n/* istanbul ignore next */\nvar retryDelay = function retryDelay(attemptIndex) {\n  return attemptIndex === 0 ? 0 : Math.min(1000 * Math.pow(2, attemptIndex), 30000);\n};\n\nfunction _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = _getPrototypeOf__default[\"default\"](Derived), result; if (hasNativeReflectConstruct) { var NewTarget = _getPrototypeOf__default[\"default\"](this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return _possibleConstructorReturn__default[\"default\"](this, result); }; }\n\nfunction _isNativeReflectConstruct() { if (typeof Reflect === \"undefined\" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === \"function\") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }\nfunction createWSClient(opts) {\n  var url = opts.url,\n      _opts$WebSocket = opts.WebSocket,\n      WebSocketImpl = _opts$WebSocket === void 0 ? WebSocket : _opts$WebSocket,\n      _opts$retryDelayMs = opts.retryDelayMs,\n      retryDelayFn = _opts$retryDelayMs === void 0 ? retryDelay : _opts$retryDelayMs;\n  /* istanbul ignore next */\n\n  if (!WebSocketImpl) {\n    throw new Error(\"No WebSocket implementation found - you probably don't want to use this on the server, but if you do you need to pass a `WebSocket`-ponyfill\");\n  }\n  /**\n   * outgoing messages buffer whilst not open\n   */\n\n\n  var outgoing = [];\n  /**\n   * pending outgoing requests that are awaiting callback\n   */\n\n  var pendingRequests = Object.create(null);\n  var connectAttempt = 0;\n  var dispatchTimer = null;\n  var connectTimer = null;\n  var activeConnection = createWS();\n  var state = 'connecting';\n  /**\n   * tries to send the list of messages\n   */\n\n  function dispatch() {\n    if (state !== 'open' || dispatchTimer) {\n      return;\n    }\n\n    dispatchTimer = setTimeout(function () {\n      dispatchTimer = null;\n\n      if (outgoing.length === 1) {\n        // single send\n        activeConnection.send(JSON.stringify(outgoing.pop()));\n      } else {\n        // batch send\n        activeConnection.send(JSON.stringify(outgoing));\n      } // clear\n\n\n      outgoing = [];\n    });\n  }\n\n  function tryReconnect() {\n    if (connectTimer || state === 'closed') {\n      return;\n    }\n\n    var timeout = retryDelayFn(connectAttempt++);\n    reconnectInMs(timeout);\n  }\n\n  function reconnect() {\n    state = 'connecting';\n    var oldConnection = activeConnection;\n    activeConnection = createWS();\n    closeIfNoPending(oldConnection);\n  }\n\n  function reconnectInMs(ms) {\n    if (connectTimer) {\n      return;\n    }\n\n    state = 'connecting';\n    connectTimer = setTimeout(reconnect, ms);\n  }\n\n  function closeIfNoPending(conn) {\n    // disconnect as soon as there are are no pending result\n    var hasPendingRequests = Object.values(pendingRequests).some(function (p) {\n      return p.ws === conn;\n    });\n\n    if (!hasPendingRequests) {\n      conn.close();\n    }\n  }\n\n  function resumeSubscriptionOnReconnect(req) {\n    if (outgoing.some(function (r) {\n      return r.id === req.op.id;\n    })) {\n      return;\n    }\n\n    request(req.op, req.callbacks);\n  }\n\n  function createWS() {\n    var conn = new WebSocket(url);\n    clearTimeout(connectTimer);\n    connectTimer = null;\n    conn.addEventListener('open', function () {\n      /* istanbul ignore next */\n      if (conn !== activeConnection) {\n        return;\n      }\n\n      connectAttempt = 0;\n      state = 'open';\n      dispatch();\n    });\n    conn.addEventListener('error', function () {\n      if (conn === activeConnection) {\n        tryReconnect();\n      }\n    });\n\n    var handleIncomingRequest = function handleIncomingRequest(req) {\n      if (req.method === 'reconnect' && conn === activeConnection) {\n        reconnect(); // notify subscribers\n\n        for (var _i = 0, _Object$values = Object.values(pendingRequests); _i < _Object$values.length; _i++) {\n          var pendingReq = _Object$values[_i];\n\n          if (pendingReq.type === 'subscription') {\n            resumeSubscriptionOnReconnect(pendingReq);\n          }\n        }\n      }\n    };\n\n    var handleIncomingResponse = function handleIncomingResponse(data) {\n      var _req$callbacks$next, _req$callbacks;\n\n      var req = data.id !== null && pendingRequests[data.id];\n\n      if (!req) {\n        // do something?\n        return;\n      }\n\n      (_req$callbacks$next = (_req$callbacks = req.callbacks).next) === null || _req$callbacks$next === void 0 ? void 0 : _req$callbacks$next.call(_req$callbacks, {\n        data: data\n      });\n\n      if (req.ws !== activeConnection && conn === activeConnection) {\n        var oldWs = req.ws; // gracefully replace old connection with this\n\n        req.ws = activeConnection;\n        closeIfNoPending(oldWs);\n      }\n\n      if ('result' in data && data.result.type === 'stopped' && conn === activeConnection) {\n        req.callbacks.complete();\n      }\n    };\n\n    conn.addEventListener('message', function (_ref) {\n      var data = _ref.data;\n      var msg = JSON.parse(data);\n\n      if ('method' in msg) {\n        handleIncomingRequest(msg);\n      } else {\n        handleIncomingResponse(msg);\n      }\n\n      if (conn !== activeConnection || state === 'closed') {\n        // when receiving a message, we close old connection that has no pending requests\n        closeIfNoPending(conn);\n      }\n    });\n    conn.addEventListener('close', function () {\n      if (activeConnection === conn) {\n        // connection might have been replaced already\n        tryReconnect();\n      }\n\n      for (var key in pendingRequests) {\n        var _req$callbacks$error, _req$callbacks2;\n\n        var req = pendingRequests[key];\n\n        if (req.ws !== conn) {\n          continue;\n        }\n\n        (_req$callbacks$error = (_req$callbacks2 = req.callbacks).error) === null || _req$callbacks$error === void 0 ? void 0 : _req$callbacks$error.call(_req$callbacks2, TRPCClientError.from(new TRPCWebSocketClosedError('WebSocket closed prematurely')));\n\n        if (req.type !== 'subscription') {\n          var _req$callbacks$comple, _req$callbacks3;\n\n          delete pendingRequests[key];\n          (_req$callbacks$comple = (_req$callbacks3 = req.callbacks).complete) === null || _req$callbacks$comple === void 0 ? void 0 : _req$callbacks$comple.call(_req$callbacks3);\n        } else if (state !== 'closed') {\n          // request restart of sub with next connection\n          resumeSubscriptionOnReconnect(req);\n        }\n      }\n    });\n    return conn;\n  }\n\n  function request(op, callbacks) {\n    var type = op.type,\n        input = op.input,\n        path = op.path,\n        id = op.id;\n    var envelope = {\n      id: id,\n      method: type,\n      params: {\n        input: input,\n        path: path\n      }\n    };\n    pendingRequests[id] = {\n      ws: activeConnection,\n      type: type,\n      callbacks: callbacks,\n      op: op\n    }; // enqueue message\n\n    outgoing.push(envelope);\n    dispatch();\n    return function () {\n      var _pendingRequests$id, _callbacks$complete;\n\n      var callbacks = (_pendingRequests$id = pendingRequests[id]) === null || _pendingRequests$id === void 0 ? void 0 : _pendingRequests$id.callbacks;\n      delete pendingRequests[id];\n      outgoing = outgoing.filter(function (msg) {\n        return msg.id !== id;\n      });\n      callbacks === null || callbacks === void 0 ? void 0 : (_callbacks$complete = callbacks.complete) === null || _callbacks$complete === void 0 ? void 0 : _callbacks$complete.call(callbacks);\n\n      if (op.type === 'subscription') {\n        outgoing.push({\n          id: id,\n          method: 'subscription.stop'\n        });\n        dispatch();\n      }\n    };\n  }\n\n  return {\n    close: function close() {\n      state = 'closed';\n      closeIfNoPending(activeConnection);\n    },\n    request: request,\n    getConnection: function getConnection() {\n      return activeConnection;\n    }\n  };\n}\n\nvar TRPCWebSocketClosedError = /*#__PURE__*/function (_Error) {\n  _inherits__default[\"default\"](TRPCWebSocketClosedError, _Error);\n\n  var _super = /*#__PURE__*/_createSuper(TRPCWebSocketClosedError);\n\n  function TRPCWebSocketClosedError(message) {\n    var _this;\n\n    _classCallCheck__default[\"default\"](this, TRPCWebSocketClosedError);\n\n    _this = _super.call(this, message);\n    _this.name = 'TRPCWebSocketClosedError';\n    Object.setPrototypeOf(_assertThisInitialized__default[\"default\"](_this), TRPCWebSocketClosedError.prototype);\n    return _this;\n  }\n\n  return _createClass__default[\"default\"](TRPCWebSocketClosedError);\n}( /*#__PURE__*/_wrapNativeSuper__default[\"default\"](Error));\n\nvar TRPCSubscriptionEndedError = /*#__PURE__*/function (_Error2) {\n  _inherits__default[\"default\"](TRPCSubscriptionEndedError, _Error2);\n\n  var _super2 = /*#__PURE__*/_createSuper(TRPCSubscriptionEndedError);\n\n  function TRPCSubscriptionEndedError(message) {\n    var _this2;\n\n    _classCallCheck__default[\"default\"](this, TRPCSubscriptionEndedError);\n\n    _this2 = _super2.call(this, message);\n    _this2.name = 'TRPCSubscriptionEndedError';\n    Object.setPrototypeOf(_assertThisInitialized__default[\"default\"](_this2), TRPCSubscriptionEndedError.prototype);\n    return _this2;\n  }\n\n  return _createClass__default[\"default\"](TRPCSubscriptionEndedError);\n}( /*#__PURE__*/_wrapNativeSuper__default[\"default\"](Error));\n\nfunction wsLink(opts) {\n  return function (runtime) {\n    var client = opts.client;\n    return function (_ref2) {\n      var op = _ref2.op;\n      return observable.observable(function (observer) {\n        var type = op.type,\n            path = op.path,\n            id = op.id,\n            context = op.context;\n        var input = runtime.transformer.serialize(op.input);\n        var isDone = false;\n        var unsub = client.request({\n          type: type,\n          path: path,\n          input: input,\n          id: id,\n          context: context\n        }, {\n          error: function error(err) {\n            isDone = true;\n            observer.error(err);\n            unsub();\n          },\n          complete: function complete() {\n            if (!isDone) {\n              isDone = true;\n              observer.error(TRPCClientError.from(new TRPCSubscriptionEndedError('Operation ended prematurely')));\n            } else {\n              observer.complete();\n            }\n          },\n          next: function next(result) {\n            observer.next(result);\n\n            if (op.type !== 'subscription') {\n              // if it isn't a subscription we don't care about next response\n              isDone = true;\n              unsub();\n              observer.complete();\n            }\n          }\n        });\n        return function () {\n          isDone = true;\n          unsub();\n        };\n      });\n    };\n  };\n}\n\nfunction ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }\n\nfunction _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys(Object(source), !0).forEach(function (key) { _defineProperty__default[\"default\"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }\n\n/** @internal */\nfunction transformOperationResult(result, runtime) {\n  var context = result.context;\n\n  if ('error' in result.data) {\n    var error = TRPCClientError.from(_objectSpread(_objectSpread({}, result.data), {}, {\n      error: runtime.transformer.deserialize(result.data.error)\n    }));\n    return {\n      ok: false,\n      error: error,\n      context: context\n    };\n  }\n\n  var data = runtime.transformer.deserialize(result.data.result.data);\n  return {\n    ok: true,\n    data: data,\n    context: context\n  };\n}\n/** @internal */\n\nfunction transformSubscriptionOperationResult(result, runtime) {\n  var context = result.context;\n\n  if ('error' in result.data) {\n    var error = TRPCClientError.from(_objectSpread(_objectSpread({}, result.data), {}, {\n      error: runtime.transformer.deserialize(result.data.error)\n    }), {\n      meta: context\n    });\n    return {\n      ok: false,\n      error: error,\n      context: context\n    };\n  }\n\n  var data = _objectSpread(_objectSpread({}, result.data.result), result.data.result.type === 'data' && {\n    data: runtime.transformer.deserialize(result.data.result.data)\n  });\n\n  return {\n    ok: true,\n    data: data,\n    context: context\n  };\n}\n\nvar idCounter = 0;\n\nfunction getRequestId() {\n  return ++idCounter;\n}\n\nvar TRPCClient = /*#__PURE__*/function () {\n  function TRPCClient(opts) {\n    var _this = this;\n\n    _classCallCheck__default[\"default\"](this, TRPCClient);\n\n    this.links = void 0;\n    this.runtime = void 0;\n\n    var _fetch = getFetch(opts === null || opts === void 0 ? void 0 : opts.fetch);\n\n    var AC = getAbortController(opts === null || opts === void 0 ? void 0 : opts.AbortController);\n\n    function getHeadersFn() {\n      if (opts.headers) {\n        var headers = opts.headers;\n        return typeof headers === 'function' ? headers : function () {\n          return headers;\n        };\n      }\n\n      return function () {\n        return {};\n      };\n    }\n\n    var transformer = opts.transformer ? 'input' in opts.transformer ? {\n      serialize: opts.transformer.input.serialize,\n      deserialize: opts.transformer.output.deserialize\n    } : opts.transformer : {\n      serialize: function serialize(data) {\n        return data;\n      },\n      deserialize: function deserialize(data) {\n        return data;\n      }\n    };\n    this.runtime = {\n      AbortController: AC,\n      fetch: _fetch,\n      headers: getHeadersFn(),\n      transformer: transformer\n    };\n\n    if ('links' in opts) {\n      this.links = opts.links.map(function (link) {\n        return link(_this.runtime);\n      });\n    } else {\n      this.links = [httpBatchLink({\n        url: opts.url\n      })(this.runtime)];\n    }\n  }\n\n  _createClass__default[\"default\"](TRPCClient, [{\n    key: \"$request\",\n    value: function $request(_ref) {\n      var type = _ref.type,\n          input = _ref.input,\n          path = _ref.path,\n          _ref$context = _ref.context,\n          context = _ref$context === void 0 ? {} : _ref$context;\n      var chain$ = createChain({\n        links: this.links,\n        op: {\n          id: getRequestId(),\n          type: type,\n          path: path,\n          input: input,\n          context: context\n        }\n      });\n      return chain$.pipe(observable.share());\n    }\n  }, {\n    key: \"requestAsPromise\",\n    value: function requestAsPromise(opts) {\n      var _this2 = this;\n\n      var req$ = this.$request(opts);\n\n      var _observableToPromise = observable.observableToPromise(req$),\n          promise = _observableToPromise.promise,\n          abort = _observableToPromise.abort;\n\n      var cancellablePromise = new Promise(function (resolve, reject) {\n        promise.then(function (result) {\n          var transformed = transformOperationResult(result, _this2.runtime);\n\n          if (transformed.ok) {\n            resolve(transformed.data);\n            return;\n          }\n\n          reject(transformed.error);\n        }).catch(function (err) {\n          reject(TRPCClientError.from(err));\n        });\n      });\n      cancellablePromise.cancel = abort;\n      return cancellablePromise;\n    }\n  }, {\n    key: \"query\",\n    value: function query(path) {\n      var _ref2;\n\n      var context = (_ref2 = arguments.length <= 2 ? undefined : arguments[2]) === null || _ref2 === void 0 ? void 0 : _ref2.context;\n      return this.requestAsPromise({\n        type: 'query',\n        path: path,\n        input: arguments.length <= 1 ? undefined : arguments[1],\n        context: context\n      });\n    }\n  }, {\n    key: \"mutation\",\n    value: function mutation(path) {\n      var _ref3;\n\n      var context = (_ref3 = arguments.length <= 2 ? undefined : arguments[2]) === null || _ref3 === void 0 ? void 0 : _ref3.context;\n      return this.requestAsPromise({\n        type: 'mutation',\n        path: path,\n        input: arguments.length <= 1 ? undefined : arguments[1],\n        context: context\n      });\n    }\n  }, {\n    key: \"subscription\",\n    value: function subscription(path, input, opts) {\n      var observable$ = this.$request({\n        type: 'subscription',\n        path: path,\n        input: input,\n        context: opts.context\n      });\n      var runtime = this.runtime;\n      return observable$.subscribe({\n        next: function next(result) {\n          var _opts$error;\n\n          var transformed = transformSubscriptionOperationResult(result, runtime);\n\n          if (transformed.ok) {\n            var _opts$next;\n\n            (_opts$next = opts.next) === null || _opts$next === void 0 ? void 0 : _opts$next.call(opts, transformed.data);\n            return;\n          }\n\n          (_opts$error = opts.error) === null || _opts$error === void 0 ? void 0 : _opts$error.call(opts, transformed.error);\n        },\n        error: function error(err) {\n          var _opts$error2;\n\n          (_opts$error2 = opts.error) === null || _opts$error2 === void 0 ? void 0 : _opts$error2.call(opts, err);\n        },\n        complete: function complete() {\n          var _opts$complete;\n\n          (_opts$complete = opts.complete) === null || _opts$complete === void 0 ? void 0 : _opts$complete.call(opts);\n        }\n      });\n    }\n  }]);\n\n  return TRPCClient;\n}();\n\n/* eslint-disable @typescript-eslint/no-explicit-any */\nfunction createTRPCClient(opts) {\n  return new TRPCClient(opts);\n}\n\nexports.TRPCClientError = TRPCClientError;\nexports.createTRPCClient = createTRPCClient;\nexports.createWSClient = createWSClient;\nexports.dedupeLink = dedupeLink;\nexports.getFetch = getFetch;\nexports.httpBatchLink = httpBatchLink;\nexports.httpLink = httpLink;\nexports.loggerLink = loggerLink;\nexports.retryLink = retryLink;\nexports.splitLink = splitLink;\nexports.wsLink = wsLink;\n"]}