From 0f6720fc203f53bf6f483e85697dde2bd9fc6499 Mon Sep 17 00:00:00 2001
From: Kacper Kielak <kielak.kacper@gmail.com>
Date: Tue, 11 Apr 2023 22:08:34 +0100
Subject: [PATCH] Fix reader issue. See
 https://github.com/Azure/fetch-event-source/pull/28

---
 package-lock.json | 6 +++---
 package.json      | 8 ++++----
 src/parse.ts      | 8 +++-----
 3 files changed, 10 insertions(+), 12 deletions(-)

diff --git a/package-lock.json b/package-lock.json
index fc3f3c7..91424d5 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,11 +1,11 @@
 {
-  "name": "@microsoft/fetch-event-source",
+  "name": "@quantum-boost/fetch-event-source",
   "version": "3.0.0",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
-      "name": "@microsoft/fetch-event-source",
+      "name": "@quantum-boost/fetch-event-source",
       "version": "3.0.0",
       "license": "MIT",
       "devDependencies": {
@@ -18,7 +18,7 @@
         "typescript": "^4.9.4"
       },
       "engines": {
-        "node": ">=16.13"
+        "node": ">=16.15"
       }
     },
     "node_modules/@babel/code-frame": {
diff --git a/package.json b/package.json
index e00e6a8..a4d9cc4 100644
--- a/package.json
+++ b/package.json
@@ -1,11 +1,11 @@
 {
-  "name": "@microsoft/fetch-event-source",
+  "name": "@quantum-boost/fetch-event-source",
   "version": "3.0.0",
   "description": "A better API for making Event Source requests, with all the features of fetch()",
   "homepage": "https://github.com/Azure/fetch-event-source#readme",
-  "repository": "github:Azure/fetch-event-source",
-  "bugs": {
-    "url": "https://github.com/Azure/fetch-event-source/issues"
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/Azure/fetch-event-source.git"
   },
   "author": "Microsoft",
   "license": "MIT",
diff --git a/src/parse.ts b/src/parse.ts
index cb26856..ae1d596 100644
--- a/src/parse.ts
+++ b/src/parse.ts
@@ -19,11 +19,9 @@ export interface EventSourceMessage {
  * @param onChunk A function that will be called on each new byte chunk in the stream.
  * @returns {Promise<void>} A promise that will be resolved when the stream closes.
  */
-export async function getBytes(stream: ReadableStream<Uint8Array>, onChunk: (arr: Uint8Array) => void) {
-    const reader = stream.getReader();
-    let result: ReadableStreamReadResult<Uint8Array>;
-    while (!(result = await reader.read()).done) {
-        onChunk(result.value);
+export async function getBytes(body: any, onChunk: any) {
+    for await (const chunk of body) {
+        onChunk(chunk);
     }
 }