wip

src/async/deserializeAsync.ts

@@ -165,6 +165,7 @@ export function createTsonParseAsyncInner(opts: TsonAsyncOptions) {
 			let nextValue = await instance.next();
 
 			while (!nextValue.done) {
+				console.log("got next value", nextValue);
 				nextValue.value.split("\n").forEach(readLine);
 
 				nextValue = await instance.next();

src/errors.ts

@@ -25,4 +25,10 @@ export class TsonPromiseRejectionError extends TsonError {
 		super(`Promise rejected`, { cause });
 		this.name = "TsonPromiseRejectionError";
 	}
+
+	static from(cause: unknown) {
+		return cause instanceof Error
+			? cause
+			: new TsonPromiseRejectionError(cause);
+	}
 }

src/handlers/tsonPromise.test.ts

@@ -398,7 +398,7 @@ test("stringify and parse promise with a promise", async () => {
 });
 
 // let's do it over an actual network connection
-test("stringify and parse promise with a promise over a network connection", async () => {
+test.only("stringify and parse promise with a promise over a network connection", async () => {
 	interface Obj {
 		promise: Promise<{
 			anotherPromise: Promise<number>;
@@ -530,7 +530,9 @@ test("does not crash node when it receives a promise rejection", async () => {
 
 	const err = await waitError(result.foo);
 
-	expect(err).toMatchInlineSnapshot("[TsonError: Promise rejected on server]");
+	expect(err).toMatchInlineSnapshot(
+		"[TsonPromiseRejectionError: Promise rejected]",
+	);
 });
 
 test("stringify promise rejection", async () => {

src/handlers/tsonPromise.ts

@@ -1,4 +1,5 @@
 import { TsonAsyncType } from "../async/asyncTypes.js";
+import { TsonPromiseRejectionError } from "../errors.js";
 
 function isPromise(value: unknown): value is Promise<unknown> {
 	return (
@@ -31,7 +32,9 @@ export const tsonPromise: TsonAsyncType<MyPromise, SerializedPromiseValue> = {
 
 				const [status, result] = value.value;
 
-				status === PROMISE_RESOLVED ? resolve(result as any) : reject(result);
+				status === PROMISE_RESOLVED
+					? resolve(result as any)
+					: reject(TsonPromiseRejectionError.from(result));
 
 				opts.onDone();
 			}
@@ -84,7 +87,7 @@ export const tsonAsyncIterator: TsonAsyncType<
 						}
 
 						case ITERATOR_ERROR: {
-							throw value[1];
+							throw TsonPromiseRejectionError.from(value[1]);
 						}
 
 						case ITERATOR_VALUE: {