{"version":3,"sources":["/home/mkabumattar/work/withrawi/rawi/dist/chunk-B2SYICJS.cjs","../src/libs/providers/ollama/utils/text-line-stream.ts"],"names":["TextLineStream","#buffer","controller","chunkText","text","EOL"],"mappings":"AAAA;ACAO,IAAMA,CAAAA,CAAN,MAAA,QAA6B,eAAgC,CAClEC,CAAAA,CAAAA,CAAU,EAAA,CAEV,WAAA,CAAA,CAAc,CACZ,KAAA,CAAM,CACJ,KAAA,CAAQC,CAAAA,EAAe,CACjB,IAAA,CAAKD,CAAAA,CAAAA,CAAQ,MAAA,GAAW,CAAA,EAE5BC,CAAAA,CAAW,OAAA,CAAQ,IAAA,CAAKD,CAAAA,CAAO,CACjC,CAAA,CACA,SAAA,CAAW,CAACE,CAAAA,CAAWD,CAAAA,CAAAA,EAAe,CACpC,IAAIE,CAAAA,CAAO,IAAA,CAAKH,CAAAA,CAAAA,CAAUE,CAAAA,CAE1B,GAAA,CAAA,CAAA,CAAA,CAAa,CACX,IAAME,CAAAA,CAAMD,CAAAA,CAAK,OAAA,CAAQ,CAAA;AAAA,CAAI,CAAA,CAE7B,EAAA,CAAIC,CAAAA,GAAQ,CAAA,CAAA,CAAI,KAAA,CAEhBH,CAAAA,CAAW,OAAA,CAAQE,CAAAA,CAAK,KAAA,CAAM,CAAA,CAAGC,CAAG,CAAC,CAAA,CACrCD,CAAAA,CAAOA,CAAAA,CAAK,KAAA,CAAMC,CAAAA,CAAM,CAAC,CAC3B,CAEA,IAAA,CAAKJ,CAAAA,CAAAA,CAAUG,CACjB,CACF,CAAC,CACH,CACF,CAAA,CAAA,cAAA;ADvBA","file":"/home/mkabumattar/work/withrawi/rawi/dist/chunk-B2SYICJS.cjs","sourcesContent":[null,"export class TextLineStream extends TransformStream<string, string> {\n  #buffer = '';\n\n  constructor() {\n    super({\n      flush: (controller) => {\n        if (this.#buffer.length === 0) return;\n\n        controller.enqueue(this.#buffer);\n      },\n      transform: (chunkText, controller) => {\n        let text = this.#buffer + chunkText;\n\n        while (true) {\n          const EOL = text.indexOf('\\n');\n\n          if (EOL === -1) break;\n\n          controller.enqueue(text.slice(0, EOL));\n          text = text.slice(EOL + 1);\n        }\n\n        this.#buffer = text;\n      },\n    });\n  }\n}\n"]}