GithubFollow/Surge_by_SukkaW
1
0
Fork 0
mirror of https://github.com/SukkaW/Surge.git synced 2025-12-12 09:10:35 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fix: proper TextDecoderStream implementation

Browse Source
This commit is contained in:
SukkaW 2024-06-02 19:54:27 +08:00
parent 9b5738f565
commit 2564860a17
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
Build/lib/text-decoder-stream.ts
View File

@ -16,18 +16,23 @@
// Modified by Sukka (https://skk.moe) to increase compatibility and performance with Bun. // Modified by Sukka (https://skk.moe) to increase compatibility and performance with Bun.
export class PolyfillTextDecoderStream extends TransformStream<Uint8Array, string> { export class PolyfillTextDecoderStream extends TransformStream<Uint8Array, string> {
readonly encoding: string;
readonly fatal: boolean; readonly fatal: boolean;
readonly ignoreBOM: boolean; readonly ignoreBOM: boolean;
constructor( constructor(
encoding: Bun.Encoding = 'utf-8', public readonly encoding: Bun.Encoding = 'utf-8',
{ fatal = false, ignoreBOM = false }: ConstructorParameters<typeof TextDecoder>[1] = {} {
fatal = false,
ignoreBOM = false
}: ConstructorParameters<typeof TextDecoder>[1] = {}
) { ) {
const decoder = new TextDecoder(encoding, { fatal, ignoreBOM }); const decoder = new TextDecoder(encoding, { fatal, ignoreBOM });
const nonLastChunkDecoderOpt: TextDecodeOptions = { stream: true };
super({ super({
transform(chunk: Uint8Array, controller: TransformStreamDefaultController<string>) { transform(chunk: Uint8Array, controller: TransformStreamDefaultController<string>) {
const decoded = decoder.decode(chunk); const decoded = decoder.decode(chunk, nonLastChunkDecoderOpt);
controller.enqueue(decoded); controller.enqueue(decoded);
}, },
flush(controller: TransformStreamDefaultController<string>) { flush(controller: TransformStreamDefaultController<string>) {
@ -43,7 +48,6 @@ export class PolyfillTextDecoderStream extends TransformStream<Uint8Array, strin
} }
}); });
this.encoding = encoding;
this.fatal = fatal; this.fatal = fatal;
this.ignoreBOM = ignoreBOM; this.ignoreBOM = ignoreBOM;
} }