Skip to content

Commit c1ae7f3

Browse files
alan-agius4clydin
authored andcommitted
refactor: update rxjs imports
Remove `rxjs/operators` legacy import
1 parent 8edee8e commit c1ae7f3

File tree

1 file changed

+9
-5
lines changed
  • packages/angular_devkit/build_angular/src/builders/ssr-dev-server

1 file changed

+9
-5
lines changed

packages/angular_devkit/build_angular/src/builders/ssr-dev-server/index.ts

+9-5
Original file line numberDiff line numberDiff line change
@@ -21,21 +21,25 @@ import type {
2121
ProxyOptions,
2222
} from 'browser-sync';
2323
import { join, resolve as pathResolve } from 'path';
24-
import { EMPTY, Observable, combineLatest, from, of, zip } from 'rxjs';
2524
import {
25+
EMPTY,
26+
Observable,
2627
catchError,
28+
combineLatest,
2729
concatMap,
2830
debounce,
2931
debounceTime,
3032
delay,
3133
finalize,
34+
from,
3235
ignoreElements,
3336
map,
34-
mapTo,
37+
of,
3538
startWith,
3639
switchMap,
3740
tap,
38-
} from 'rxjs/operators';
41+
zip,
42+
} from 'rxjs';
3943
import * as url from 'url';
4044
import { assertIsError } from '../../utils/error';
4145
import { Schema } from './schema';
@@ -99,7 +103,7 @@ export function execute(
99103
}
100104

101105
return startNodeServer(s, nodeServerPort, context.logger, !!options.inspect).pipe(
102-
mapTo([b, s]),
106+
map(() => [b, s]),
103107
catchError((err) => {
104108
context.logger.error(`A server error has occurred.\n${mapErrorToMessage(err)}`);
105109

@@ -153,7 +157,7 @@ export function execute(
153157
**
154158
`);
155159
}),
156-
mapTo(builderOutput),
160+
map(() => builderOutput),
157161
);
158162
}
159163
}),

0 commit comments

Comments
 (0)