build: update to rxjs 7

G3 is now using RXJS version 7 which makes it possible for the CLI to also be updated to RXJS 7.

NB: this change does not remove all usages of the deprecated APIs.

Closes #24371

Author: alan-agius4

bin/devkit-admin

@@ -35,7 +35,7 @@ let logger = null;
 try {
   logger = new (require('@angular-devkit/core').logging.IndentLogger)('root');
   const colors = require('ansi-colors').create();
-  const filter = require('rxjs/operators').filter;
+  const filter = require('rxjs').filter;
 
   logger
     .pipe(filter(entry => (entry.level !== 'debug' || args.verbose)))

goldens/public-api/angular_devkit/architect/index.md

@@ -10,9 +10,9 @@ import { JsonObject } from '@angular-devkit/core';
 import { JsonValue } from '@angular-devkit/core';
 import { logging } from '@angular-devkit/core';
 import { Observable } from 'rxjs';
+import { ObservableInput } from 'rxjs';
 import { Observer } from 'rxjs';
 import { schema } from '@angular-devkit/core';
-import { SubscribableOrPromise } from 'rxjs';
 
 // @public (undocumented)
 export class Architect {
@@ -67,7 +67,7 @@ export type BuilderInput = json.JsonObject & Schema;
 export type BuilderOutput = json.JsonObject & Schema_2;
 
 // @public
-export type BuilderOutputLike = AsyncIterable<BuilderOutput> | SubscribableOrPromise<BuilderOutput> | BuilderOutput;
+export type BuilderOutputLike = ObservableInput<BuilderOutput> | BuilderOutput;
 
 // @public (undocumented)
 export type BuilderProgress = json.JsonObject & Schema_3 & TypedBuilderProgress;
@@ -97,6 +97,7 @@ export type BuilderRegistry = Registry<json.JsonObject, BuilderInput, BuilderOut
 export interface BuilderRun {
     id: number;
     info: BuilderInfo;
+    lastOutput: Promise<BuilderOutput>;
     output: Observable<BuilderOutput>;
     progress: Observable<BuilderProgressReport>;
     result: Promise<BuilderOutput>;

goldens/public-api/angular_devkit/core/index.md

@@ -7,11 +7,11 @@
 import { ErrorObject } from 'ajv';
 import { Format } from 'ajv';
 import { Observable } from 'rxjs';
+import { ObservableInput } from 'rxjs';
 import { Operator } from 'rxjs';
 import { PartialObserver } from 'rxjs';
 import { Position } from 'source-map';
 import { Subject } from 'rxjs';
-import { SubscribableOrPromise } from 'rxjs';
 import { Subscription } from 'rxjs';
 import { ValidateFunction } from 'ajv';
 
@@ -714,7 +714,7 @@ interface PromptDefinition {
 }
 
 // @public (undocumented)
-type PromptProvider = (definitions: Array<PromptDefinition>) => SubscribableOrPromise<{
+type PromptProvider = (definitions: Array<PromptDefinition>) => ObservableInput<{
     [id: string]: JsonValue;
 }>;
 

package.json

@@ -193,7 +193,7 @@
     "puppeteer": "18.2.1",
     "quicktype-core": "22.0.0",
     "resolve-url-loader": "5.0.0",
-    "rxjs": "6.6.7",
+    "rxjs": "7.8.0",
     "sass": "1.58.1",
     "sass-loader": "13.2.0",
     "sauce-connect-proxy": "https://saucelabs.com/downloads/sc-4.8.1-linux.tar.gz",

packages/angular/cli/BUILD.bazel

@@ -142,7 +142,6 @@ ts_library(
         "//packages/angular_devkit/schematics",
         "//packages/angular_devkit/schematics/testing",
         "@npm//@types/semver",
-        "@npm//rxjs",
     ],
 )
 

packages/angular/cli/package.json

@@ -41,9 +41,6 @@
     "symbol-observable": "4.0.0",
     "yargs": "17.6.2"
   },
-  "devDependencies": {
-    "rxjs": "6.6.7"
-  },
   "ng-update": {
     "migrations": "@schematics/angular/migrations/migration-collection.json",
     "packageGroup": {

packages/angular/cli/src/command-builder/architect-base-command-module.ts

@@ -85,8 +85,7 @@ export abstract class ArchitectBaseCommandModule<T extends object>
     }
 
     try {
-      const { error, success } = await run.output.toPromise();
-
+      const { error, success } = await run.lastOutput;
       if (error) {
         logger.error(error);
       }

packages/angular_devkit/architect/builders/all-of.ts

@@ -7,8 +7,7 @@
  */
 
 import { json } from '@angular-devkit/core';
-import { EMPTY, from, of } from 'rxjs';
-import { map, mergeMap } from 'rxjs/operators';
+import { EMPTY, from, map, mergeMap, of } from 'rxjs';
 import { BuilderOutput, BuilderRun, createBuilder } from '../src';
 import { Schema as OperatorSchema } from './operator-schema';
 

packages/angular_devkit/architect/builders/concat.ts

@@ -7,8 +7,7 @@
  */
 
 import { json } from '@angular-devkit/core';
-import { from, of } from 'rxjs';
-import { concatMap, first, last, map, switchMap } from 'rxjs/operators';
+import { concatMap, first, from, last, map, of, switchMap } from 'rxjs';
 import { BuilderOutput, BuilderRun, createBuilder } from '../src';
 import { Schema as OperatorSchema } from './operator-schema';
 

packages/angular_devkit/architect/node/BUILD.bazel

@@ -40,6 +40,7 @@ ts_library(
         ":node",
         "//packages/angular_devkit/architect",
         "//tests/angular_devkit/architect/node/jobs:jobs_test_lib",
+        "@npm//rxjs",
     ],
 )