fixup! refactor: update to angular v13 with APF v13 output

Author: atscott

server/src/tests/ngcc_spec.ts

@@ -9,6 +9,8 @@
 import * as child_process from 'child_process';
 import {EventEmitter} from 'events';
 import {join, resolve} from 'path';
+import {interval, Subject} from 'rxjs';
+import {takeUntil} from 'rxjs/operators';
 
 import {resolveAndRunNgcc} from '../ngcc';
 
@@ -17,13 +19,22 @@ const WORKSPACE_ROOT = join(PACKAGE_ROOT, 'integration', 'workspace');
 const PROJECT = join(WORKSPACE_ROOT, 'projects', 'demo');
 
 describe('resolveAndRunNgcc', () => {
+  const afterEach$ = new Subject<void>();
+  afterEach(() => {
+    afterEach$.next();
+  })
+
   it('runs ngcc from node_modules where ngcc is resolved to', async () => {
     const fakeChild = new EventEmitter();
     const spy = spyOn(child_process, 'fork').and.returnValue(fakeChild as any);
     // Note that tsconfig.json is in the project directory
     const tsconfig = join(PROJECT, 'tsconfig.json');
+    // Because resolveNgcc is async, we need to periodically emit `close` from the child since
+    // `resolveAndRunNgcc` subscribes after the async resolveNgcc.
+    interval(500).pipe(takeUntil(afterEach$)).subscribe(() => {
+      fakeChild.emit('close', 0 /* exit code */);
+    });
     const promise = resolveAndRunNgcc(tsconfig, {report() {}});
-    fakeChild.emit('close', 0 /* exit code */);
     await expectAsync(promise).toBeResolved();
     expect(spy.calls.count()).toBe(1);
     // First arg is the ngcc binary, second arg is program arguments, third