add some dry to clean-up

Author: yaacovCR

Diff for: src/transform/transformResult.ts

@@ -224,14 +224,7 @@ function processCompleted(
         incremental.push(incrementalResult);
       }
 
-      context.pendingResultsById.delete(completedResult.id);
-      const path = pendingResult.path.join('.');
-      const labels = context.pendingLabelsByPath.get(path);
-      invariant(labels != null);
-      labels.delete(label);
-      if (labels.size === 0) {
-        context.pendingLabelsByPath.delete(path);
-      }
+      deletePendingResult(context, pendingResult, label);
       continue;
     }
 
@@ -283,18 +276,26 @@ function processCompleted(
 
     incremental.push(incrementalResult);
 
-    context.pendingResultsById.delete(completedResult.id);
-    const path = pendingResult.path.join('.');
-    const labels = context.pendingLabelsByPath.get(path);
-    invariant(labels != null);
-    labels.delete(label);
-    if (labels.size === 0) {
-      context.pendingLabelsByPath.delete(path);
-    }
+    deletePendingResult(context, pendingResult, label);
   }
   return incremental;
 }
 
+function deletePendingResult(
+  context: TransformationContext,
+  pendingResult: PendingResult,
+  label: string,
+): void {
+  context.pendingResultsById.delete(pendingResult.id);
+  const path = pendingResult.path.join('.');
+  const labels = context.pendingLabelsByPath.get(path);
+  invariant(labels != null);
+  labels.delete(label);
+  if (labels.size === 0) {
+    context.pendingLabelsByPath.delete(path);
+  }
+}
+
 function transformInitialResult<
   T extends ExecutionResult | InitialIncrementalExecutionResult,
 >(context: TransformationContext, result: T): T {