From 6bd56bdc93efc71c70d0034067f7f86d76d022ff Mon Sep 17 00:00:00 2001
From: Alan Agius <alanagius@google.com>
Date: Tue, 5 Dec 2023 18:55:38 +0000
Subject: [PATCH] refactor: update rxjs imports

Remove `rxjs/operators` legacy import

(cherry picked from commit c1ae7f3b33c2737a52ced247ca489039c065ed21)
---
 .../src/builders/ssr-dev-server/index.ts           | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/packages/angular_devkit/build_angular/src/builders/ssr-dev-server/index.ts b/packages/angular_devkit/build_angular/src/builders/ssr-dev-server/index.ts
index d55d03ce0042..895b6137f666 100644
--- a/packages/angular_devkit/build_angular/src/builders/ssr-dev-server/index.ts
+++ b/packages/angular_devkit/build_angular/src/builders/ssr-dev-server/index.ts
@@ -21,21 +21,25 @@ import type {
   ProxyOptions,
 } from 'browser-sync';
 import { join, resolve as pathResolve } from 'path';
-import { EMPTY, Observable, combineLatest, from, of, zip } from 'rxjs';
 import {
+  EMPTY,
+  Observable,
   catchError,
+  combineLatest,
   concatMap,
   debounce,
   debounceTime,
   delay,
   finalize,
+  from,
   ignoreElements,
   map,
-  mapTo,
+  of,
   startWith,
   switchMap,
   tap,
-} from 'rxjs/operators';
+  zip,
+} from 'rxjs';
 import * as url from 'url';
 import { assertIsError } from '../../utils/error';
 import { Schema } from './schema';
@@ -99,7 +103,7 @@ export function execute(
           }
 
           return startNodeServer(s, nodeServerPort, context.logger, !!options.inspect).pipe(
-            mapTo([b, s]),
+            map(() => [b, s]),
             catchError((err) => {
               context.logger.error(`A server error has occurred.\n${mapErrorToMessage(err)}`);
 
@@ -153,7 +157,7 @@ export function execute(
                 **
               `);
           }),
-          mapTo(builderOutput),
+          map(() => builderOutput),
         );
       }
     }),