rename StreamRecord to StreamItemsRecord

Author: yaacovCR

src/execution/execute.ts

@@ -1857,7 +1857,7 @@ function executeStreamField(
   label?: string,
   parentContext?: IncrementalDataRecord,
 ): IncrementalDataRecord {
-  const incrementalDataRecord = new StreamRecord({
+  const incrementalDataRecord = new StreamItemsRecord({
     label,
     path: itemPath,
     parentContext,
@@ -1953,7 +1953,7 @@ async function executeStreamAsyncIteratorItem(
   fieldGroup: FieldGroup,
   info: GraphQLResolveInfo,
   itemType: GraphQLOutputType,
-  incrementalDataRecord: StreamRecord,
+  incrementalDataRecord: StreamItemsRecord,
   itemPath: Path,
 ): Promise<IteratorResult<unknown>> {
   let item;
@@ -2033,7 +2033,7 @@ async function executeStreamAsyncIterator(
   // eslint-disable-next-line no-constant-condition
   while (true) {
     const itemPath = addPath(path, index, undefined);
-    const incrementalDataRecord = new StreamRecord({
+    const incrementalDataRecord = new StreamItemsRecord({
       label,
       path: itemPath,
       parentContext: previousIncrementalDataRecord,
@@ -2111,7 +2111,7 @@ function filterSubsequentPayloads(
     }
     // incrementalDataRecord path points to nulled error field
     if (
-      isStreamRecord(incrementalDataRecord) &&
+      isStreamItemsRecord(incrementalDataRecord) &&
       incrementalDataRecord.iterator?.return
     ) {
       incrementalDataRecord.iterator.return().catch(() => {
@@ -2132,7 +2132,7 @@ function getCompletedIncrementalResults(
       continue;
     }
     exeContext.subsequentResults.delete(incrementalDataRecord);
-    if (isStreamRecord(incrementalDataRecord)) {
+    if (isStreamItemsRecord(incrementalDataRecord)) {
       const items = incrementalDataRecord.items;
       if (incrementalDataRecord.isCompletedIterator) {
         // async iterable resolver just finished but there may be pending payloads
@@ -2198,7 +2198,7 @@ function yieldSubsequentPayloads(
     const promises: Array<Promise<IteratorResult<unknown>>> = [];
     exeContext.subsequentResults.forEach((incrementalDataRecord) => {
       if (
-        isStreamRecord(incrementalDataRecord) &&
+        isStreamItemsRecord(incrementalDataRecord) &&
         incrementalDataRecord.iterator?.return
       ) {
         promises.push(incrementalDataRecord.iterator.return());
@@ -2275,7 +2275,7 @@ class DeferredFragmentRecord {
   }
 }
 
-class StreamRecord {
+class StreamItemsRecord {
   type: 'stream';
   errors: Array<GraphQLError>;
   label: string | undefined;
@@ -2330,10 +2330,10 @@ class StreamRecord {
   }
 }
 
-type IncrementalDataRecord = DeferredFragmentRecord | StreamRecord;
+type IncrementalDataRecord = DeferredFragmentRecord | StreamItemsRecord;
 
-function isStreamRecord(
+function isStreamItemsRecord(
   incrementalDataRecord: IncrementalDataRecord,
-): incrementalDataRecord is StreamRecord {
+): incrementalDataRecord is StreamItemsRecord {
   return incrementalDataRecord.type === 'stream';
 }