fix

src/async/deserializeAsync.ts

@@ -155,7 +155,10 @@ export function createTsonParseAsyncInner(opts: TsonAsyncOptions) {
 				item.controller.close();
 			}
 
-			assert(streamByIndex.size === 0, "Not all streams were closed");
+			assert(
+				streamByIndex.size === 0,
+				"Not all streams were processed or done at the end of the stream",
+			);
 		}
 
 		async function init() {

src/handlers/tsonAsyncIterable.ts

@@ -36,7 +36,6 @@ export const tsonAsyncIterator: TsonAsyncType<
 
 						case ITERATOR_VALUE: {
 							yield value[1];
-							break;
 						}
 					}
 				}

src/index.test.ts

@@ -178,6 +178,6 @@ test("async: bad values", async () => {
 	});
 
 	expect(onErrorSpy.mock.calls[0][0]).toMatchInlineSnapshot(
-		'[TsonError: Stream interrupted: Not all streams were closed]',
+		'[TsonError: Stream interrupted: Not all streams were processed or done at the end of the stream]',
 	);
 });