{"version":3,"file":"writer.cjs","sources":["../../../../../../src/mods/snowflake/turbo/writer.ts"],"sourcesContent":["import { Opaque, Writable } from \"@hazae41/binary\";\nimport { TurboFrame } from \"./frame.js\";\nimport { SecretTurboDuplex } from \"./stream.js\";\n\nexport class SecretTurboWriter {\n\n  constructor(\n    readonly parent: SecretTurboDuplex\n  ) { }\n\n  async onStart() {\n    await this.parent.resolveOnStart.promise\n\n    const token = this.parent.class.token\n    this.parent.output.enqueue(new Opaque(token))\n\n    const client = this.parent.client\n    this.parent.output.enqueue(new Opaque(client))\n  }\n\n  async onWrite(fragment: Writable) {\n    const frame = TurboFrame.createOrThrow({ padding: false, fragment })\n    this.parent.output.enqueue(frame)\n  }\n\n}\n\n"],"names":["Opaque","frame","TurboFrame"],"mappings":";;;;;MAIa,iBAAiB,CAAA;AAGjB,IAAA,MAAA,CAAA;AADX,IAAA,WAAA,CACW,MAAyB,EAAA;QAAzB,IAAM,CAAA,MAAA,GAAN,MAAM,CAAmB;KAC/B;AAEL,IAAA,MAAM,OAAO,GAAA;AACX,QAAA,MAAM,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,OAAO,CAAA;QAExC,MAAM,KAAK,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,KAAK,CAAA;AACrC,QAAA,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,IAAIA,aAAM,CAAC,KAAK,CAAC,CAAC,CAAA;AAE7C,QAAA,MAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,MAAM,CAAA;AACjC,QAAA,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,IAAIA,aAAM,CAAC,MAAM,CAAC,CAAC,CAAA;KAC/C;IAED,MAAM,OAAO,CAAC,QAAkB,EAAA;AAC9B,QAAA,MAAMC,OAAK,GAAGC,gBAAU,CAAC,aAAa,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,QAAQ,EAAE,CAAC,CAAA;QACpE,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,OAAO,CAACD,OAAK,CAAC,CAAA;KAClC;AAEF;;;;"}