don't send completed if pending was not sent

as now we hae true inlining

Author: yaacovCR

src/execution/IncrementalPublisher.ts

@@ -584,10 +584,15 @@ export class IncrementalPublisher {
       }
       if (isStreamItemsRecord(subsequentResultRecord)) {
         if (subsequentResultRecord.isFinalRecord) {
-          newPendingSources.delete(subsequentResultRecord.streamRecord);
-          completedResults.push(
-            this._completedRecordToResult(subsequentResultRecord.streamRecord),
-          );
+          if (newPendingSources.has(subsequentResultRecord.streamRecord)) {
+            newPendingSources.delete(subsequentResultRecord.streamRecord);
+          } else {
+            completedResults.push(
+              this._completedRecordToResult(
+                subsequentResultRecord.streamRecord,
+              ),
+            );
+          }
         }
         if (subsequentResultRecord.isCompletedAsyncIterator) {
           // async iterable resolver just finished but there may be pending payloads
@@ -650,10 +655,13 @@ export class IncrementalPublisher {
           );
         }
       } else {
-        newPendingSources.delete(subsequentResultRecord);
-        completedResults.push(
-          this._completedRecordToResult(subsequentResultRecord),
-        );
+        if (newPendingSources.has(subsequentResultRecord)) {
+          newPendingSources.delete(subsequentResultRecord);
+        } else {
+          completedResults.push(
+            this._completedRecordToResult(subsequentResultRecord),
+          );
+        }
         if (subsequentResultRecord.errors.length > 0) {
           continue;
         }

src/execution/__tests__/defer-test.ts

@@ -1191,11 +1191,7 @@ describe('Execute: defer directive', () => {
             path: ['hero', 'nestedObject', 'deeperObject'],
           },
         ],
-        completed: [
-          { path: ['hero'] },
-          { path: ['hero', 'nestedObject'] },
-          { path: ['hero', 'nestedObject', 'deeperObject'] },
-        ],
+        completed: [{ path: ['hero'] }],
         hasNext: false,
       },
     ]);
@@ -1261,7 +1257,6 @@ describe('Execute: defer directive', () => {
         completed: [
           { path: ['hero'] },
           { path: ['hero', 'nestedObject', 'deeperObject'] },
-          { path: ['hero', 'nestedObject', 'deeperObject'] },
         ],
         hasNext: false,
       },
@@ -2094,12 +2089,7 @@ describe('Execute: defer directive', () => {
             path: ['hero'],
           },
         ],
-        completed: [
-          { path: ['hero'] },
-          { path: ['hero', 'friends', 0] },
-          { path: ['hero', 'friends', 1] },
-          { path: ['hero', 'friends', 2] },
-        ],
+        completed: [{ path: ['hero'] }],
         hasNext: false,
       },
     ]);

src/execution/__tests__/stream-test.ts

@@ -355,8 +355,6 @@ describe('Execute: stream directive', () => {
         completed: [
           { path: ['friendList'] },
           { path: ['friendList', 0, 'appearsIn'] },
-          { path: ['friendList', 1, 'appearsIn'] },
-          { path: ['friendList', 2, 'appearsIn'] },
         ],
         hasNext: false,
       },
@@ -404,15 +402,7 @@ describe('Execute: stream directive', () => {
             path: ['friendList', 0],
           },
         ],
-        completed: [
-          { path: ['friendList', 0] },
-          { path: ['friendList'] },
-          { path: ['friendList', 1] },
-          { path: ['friendList', 2] },
-          { path: ['friendList', 0, 'appearsIn'] },
-          { path: ['friendList', 1, 'appearsIn'] },
-          { path: ['friendList', 2, 'appearsIn'] },
-        ],
+        completed: [{ path: ['friendList', 0] }, { path: ['friendList'] }],
         hasNext: false,
       },
     ]);