{"version":3,"file":"snowflake.cjs","sources":["../../../../../src/mods/snowflake/snowflake.ts"],"sourcesContent":["import { Opaque, Writable } from \"@hazae41/binary\"\nimport { KcpDuplex } from \"@hazae41/kcp\"\nimport { SmuxDuplex } from \"@hazae41/smux\"\nimport { TurboDuplex } from \"mods/snowflake/turbo/stream.js\"\n\nexport function createSnowflakeStream(raw: { outer: ReadableWritablePair<Opaque, Writable> }): { outer: ReadableWritablePair<Opaque, Writable> } {\n  const turbo = new TurboDuplex()\n  const kcp = new KcpDuplex({ lowDelay: 100, highDelay: 1000 })\n  const smux = new SmuxDuplex()\n\n  raw.outer.readable.pipeTo(turbo.inner.writable).catch(() => { })\n  turbo.inner.readable.pipeTo(raw.outer.writable).catch(() => { })\n\n  turbo.outer.readable.pipeTo(kcp.inner.writable).catch(() => { })\n  kcp.inner.readable.pipeTo(turbo.outer.writable).catch(() => { })\n\n  kcp.outer.readable.pipeTo(smux.inner.writable).catch(() => { })\n  smux.inner.readable.pipeTo(kcp.outer.writable).catch(() => { })\n\n  return smux\n}\n"],"names":["TurboDuplex","kcp","KcpDuplex","smux","SmuxDuplex"],"mappings":";;;;;;AAKM,SAAU,qBAAqB,CAAC,GAAsD,EAAA;AAC1F,IAAA,MAAM,KAAK,GAAG,IAAIA,kBAAW,EAAE,CAAA;AAC/B,IAAA,MAAMC,KAAG,GAAG,IAAIC,aAAS,CAAC,EAAE,QAAQ,EAAE,GAAG,EAAE,SAAS,EAAE,IAAI,EAAE,CAAC,CAAA;AAC7D,IAAA,MAAMC,MAAI,GAAG,IAAIC,eAAU,EAAE,CAAA;IAE7B,GAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;IAChE,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;IAEhE,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAACH,KAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;IAChEA,KAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;IAEhEA,KAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAACE,MAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;IAC/DA,MAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAACF,KAAG,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,MAAK,GAAI,CAAC,CAAA;AAE/D,IAAA,OAAOE,MAAI,CAAA;AACb;;;;"}