From 45f38f19f791057fbeebbb97875f7b5fc7df257a Mon Sep 17 00:00:00 2001
From: Phil Pluckthun <phil@kitten.sh>
Date: Tue, 14 Mar 2023 18:27:14 +0000
Subject: [PATCH] Add closing signal if it's missing

---
 packages/core/src/internal/fetchSource.ts | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/packages/core/src/internal/fetchSource.ts b/packages/core/src/internal/fetchSource.ts
index fd70350d21..4b2185d6eb 100644
--- 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: true };
 }
 
 async function* fetchOperation(