fix: more lax abort handling (#74)

Author: KATT

examples/async/src/tsonOptions.ts

@@ -1,5 +1,4 @@
 import {
-	TsonAbortError,
 	TsonAsyncOptions,
 	createTsonParseEventSource,
 	createTsonParseJsonStreamResponse,
@@ -32,9 +31,6 @@ export const createJsonStreamResponse =
 export const parseJsonStreamResponse =
 	createTsonParseJsonStreamResponse(tsonOptions);
 
-export function isAbortError(err: unknown): err is TsonAbortError {
-	return (
-		err instanceof TsonAbortError ||
-		(err instanceof Error && err.cause === TsonAbortError)
-	);
+export function isAbortError(err: unknown): err is Error {
+	return err instanceof Error && err.message.includes("aborted");
 }

src/async/asyncErrors.ts

@@ -45,7 +45,7 @@ export class TsonStreamInterruptedError extends TsonError {
 
 export class TsonAbortError extends TsonError {
 	constructor(cause: unknown) {
-		super("Aborted", { cause });
+		super("The user aborted a request.", { cause });
 		this.name = "TsonAbortError";
 	}
 }

src/async/deserializeAsync.ts

@@ -162,7 +162,7 @@ function createTsonDeserializer(opts: TsonAsyncOptions) {
 		}
 
 		return await init().catch((cause: unknown) => {
-			throw new TsonError("Failed to initialize TSON stream", { cause });
+			throw new TsonStreamInterruptedError(cause);
 		});
 	};
 }

src/index.test.ts

@@ -134,6 +134,6 @@ test("async: bad init", async () => {
 	});
 
 	expect(err).toMatchInlineSnapshot(
-		"[TsonError: Failed to initialize TSON stream]",
+		"[TsonStreamInterruptedError: Stream interrupted: Stream ended unexpectedly (state 0)]",
 	);
 });