feat: configurable TextDecoder instance

trpc · Oct 26, 2023 · d56277e · d56277e
1 parent fc356de
commit d56277e
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/src/async/asyncTypes.ts b/src/async/asyncTypes.ts
@@ -1,3 +1,4 @@
+import { TextDecoderEsque } from "../internals/esque.js";
 import {
 	TsonBranded,
 	TsonType,
@@ -66,6 +67,7 @@ export interface TsonAsyncOptions {
 	 * @default `${crypto.randomUUID} if available, otherwise a random string generated by Math.random`
 	 */
 	nonce?: () => number | string;
+	textDecoder?: TextDecoderEsque;
 
 	/**
 	 * The list of types to use

diff --git a/src/async/deserializeAsync.ts b/src/async/deserializeAsync.ts
@@ -344,10 +344,11 @@ export function createTsonParseEventSource(opts: TsonAsyncOptions) {
 export function createTsonParseJsonStreamResponse(opts: TsonAsyncOptions) {
 	const instance = createTsonParseAsync(opts);
 
+	const textDecoder = opts.textDecoder ?? new TextDecoder();
+
 	return async <TValue = unknown>(response: Response) => {
 		assert(response.body, "Response body is empty");
 
-		const textDecoder = new TextDecoder();
 		const stringIterator = mapIterable(
 			readableStreamToAsyncIterable(response.body),
 			(v) => textDecoder.decode(v),

diff --git a/src/internals/esque.ts b/src/internals/esque.ts
@@ -0,0 +1,6 @@
+/**
+ * @internal
+ */
+export interface TextDecoderEsque {
+	decode(chunk: Uint8Array): string;
+}