Add closing signal if it's missing

urql-graphql · Mar 14, 2023 · 8ce67c3 · 8ce67c3
1 parent 044b870
commit 8ce67c3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/core/src/internal/fetchSource.ts b/packages/core/src/internal/fetchSource.ts
@@ -32,6 +32,7 @@ async function* parseMultipartChunks(response: Response, contentType: string) {
   let buffer = '';
   let isPreamble = true;
   let boundaryIndex: number;
+  let payload: any;
 
   chunks: for await (const chunk of streamBody(response)) {
     buffer += chunk;
@@ -43,7 +44,6 @@ async function* parseMultipartChunks(response: Response, contentType: string) {
           buffer.indexOf('\r\n\r\n') + 4,
           boundaryIndex
         );
-        let payload: any;
         try {
           yield (payload = JSON.parse(chunk));
         } catch (_error) {}
@@ -54,6 +54,8 @@ async function* parseMultipartChunks(response: Response, contentType: string) {
       }
     }
   }
+
+  if (payload && payload.hasNext) yield { hasNext: false };
 }
 
 async function* fetchOperation(