Break stream on done event without enqueuing it

Author: mattt

lib/stream.js

@@ -79,6 +79,10 @@ function createReadableStream({ url, fetch, options = {} }) {
         .pipeThrough(new EventSourceParserStream());
 
       for await (const event of streamAsyncIterator(stream)) {
+        if (event.event === "done") {
+          break;
+        }
+
         if (event.event === "error") {
           controller.error(new Error(event.data));
           break;
@@ -87,10 +91,6 @@ function createReadableStream({ url, fetch, options = {} }) {
         controller.enqueue(
           new ServerSentEvent(event.event, event.data, event.id)
         );
-
-        if (event.event === "done") {
-          break;
-        }
       }
 
       controller.close();