diff --git a/cli/tests/unit/http_test.ts b/cli/tests/unit/http_test.ts index 6a57c2fd10..8ff31b5f73 100644 --- a/cli/tests/unit/http_test.ts +++ b/cli/tests/unit/http_test.ts @@ -863,37 +863,25 @@ Deno.test( const ev = await httpConn.nextRequest(); const { respondWith } = ev!; - const { readable, writable } = new TransformStream(); - const writer = writable.getWriter(); - - async function writeResponse() { - await delay(50); - await writer.write( - new TextEncoder().encode( - "written to the writable side of a TransformStream", - ), - ); - await writer.close(); - } - const errors: Error[] = []; - const writePromise = writeResponse() - .catch((error: Error) => { + const readable = new ReadableStream({ + async pull(controller) { + client.close(); + await delay(100); + controller.enqueue(new TextEncoder().encode( + "written to the writable side of a TransformStream", + )); + controller.close(); + }, + cancel(error) { errors.push(error); - }); + }, + }); const res = new Response(readable); - const respondPromise = respondWith(res) - .catch((error: Error) => errors.push(error)); - - client.close(); - - await Promise.all([ - writePromise, - respondPromise, - ]); + await respondWith(res).catch((error: Error) => errors.push(error)); httpConn.close(); listener.close();