add comment regarding stream terminators

yaacovCR · yaacovCR · commit 6e44e3a1b85a · 2024-04-17T23:09:26.000+03:00
diff --git a/src/execution/execute.ts b/src/execution/execute.ts
@@ -2085,6 +2085,8 @@ function firstSyncStreamItems(
       }
 
       currentIndex = results.length - 1;
+      // If a non-reconcilable stream items result was encountered, then the stream terminates in error.
+      // Otherwise, add a stream terminator.
       let currentResult = erroredSynchronously
         ? results[currentIndex]
         : prependNextStreamItems(results[currentIndex], {

Original file line number	Diff line number	Diff line change
`@@ -2085,6 +2085,8 @@ function firstSyncStreamItems(`
`2085`	`2085`	`}`
`2086`	`2086`
`2087`	`2087`	`currentIndex = results.length - 1;`
	`2088`	`+ // If a non-reconcilable stream items result was encountered, then the stream terminates in error.`
	`2089`	`+ // Otherwise, add a stream terminator.`
`2088`	`2090`	`let currentResult = erroredSynchronously`
`2089`	`2091`	`? results[currentIndex]`
`2090`	`2092`	`: prependNextStreamItems(results[currentIndex], {`