From 8a39fd62c65447513c6fef52850cba6d93c63f17 Mon Sep 17 00:00:00 2001 From: Phil Pluckthun Date: Tue, 14 Mar 2023 17:07:19 +0000 Subject: [PATCH] Remove hasResults check --- packages/core/src/internal/fetchSource.ts | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/packages/core/src/internal/fetchSource.ts b/packages/core/src/internal/fetchSource.ts index fa5f1b6a74..de95a33e50 100644 --- a/packages/core/src/internal/fetchSource.ts +++ b/packages/core/src/internal/fetchSource.ts @@ -34,8 +34,8 @@ async function* fetchOperation( fetchOptions: RequestInit ) { let abortController: AbortController | void; + let result: OperationResult | null = null; let response: Response; - let hasResults = false; try { if (typeof AbortController !== 'undefined') { @@ -61,9 +61,7 @@ async function* fetchOperation( let buffer = ''; let isPreamble = true; - let result: OperationResult | null = null; chunks: for await (const data of iterator) { - hasResults = true; buffer += toString(data); let boundaryIndex: number; @@ -88,7 +86,8 @@ async function* fetchOperation( } catch (_error) {} if (next.startsWith('--') || (payload && !payload.hasNext)) { - if (!result) yield makeResult(operation, {}, response); + if (!result) + yield (result = makeResult(operation, {}, response)); break chunks; } } @@ -97,7 +96,7 @@ async function* fetchOperation( } } } catch (error: any) { - if (hasResults) { + if (result) { throw error; }