diff --git a/tests/streaming.test.ts b/tests/streaming.test.ts index 4a3ff99e..29da8243 100644 --- a/tests/streaming.test.ts +++ b/tests/streaming.test.ts @@ -226,7 +226,10 @@ test('error handling', async () => { yield Buffer.from('\n\n'); } - const stream = Stream.fromSSEResponse(new Response(await iteratorToStream(body())), new AbortController()); + const stream = Stream.fromSSEResponse( + new Response(await ReadableStreamFrom(body())), + new AbortController(), + ); const err = expect( (async () => {