refactor: Update rxjs operators to be lettable.

Author: Brocco

package-lock.json

@@ -80,7 +80,7 @@
     "postcss-url": "^7.1.2",
     "raw-loader": "^0.5.1",
     "resolve": "^1.1.7",
-    "rxjs": "^5.5.2",
+    "rxjs": "^5.5.5",
     "sass-loader": "^6.0.3",
     "semver": "^5.3.0",
     "silent-error": "^1.0.0",

package.json

@@ -3,8 +3,6 @@ const stringUtils = require('ember-cli-string-utils');
 import { oneLine } from 'common-tags';
 import { CliConfig } from '../models/config';
 
-import 'rxjs/add/observable/of';
-import 'rxjs/add/operator/ignoreElements';
 import {
   getCollection,
   getEngineHost

packages/@angular/cli/commands/generate.ts

@@ -65,7 +65,7 @@
     "postcss-url": "^7.1.2",
     "raw-loader": "^0.5.1",
     "resolve": "^1.1.7",
-    "rxjs": "^5.5.2",
+    "rxjs": "^5.5.5",
     "sass-loader": "^6.0.3",
     "semver": "^5.1.0",
     "silent-error": "^1.0.0",

packages/@angular/cli/package.json

@@ -12,7 +12,7 @@ import { of as observableOf } from 'rxjs/observable/of';
 import * as path from 'path';
 import chalk from 'chalk';
 import { CliConfig } from '../models/config';
-import { concat, ignoreElements } from 'rxjs/operators';
+import { concat, concatMap, ignoreElements, map } from 'rxjs/operators';
 import { getCollection, getSchematic } from '../utilities/schematics';
 
 const { green, red, yellow } = chalk;
@@ -110,14 +110,14 @@ export default Task.extend({
     });
 
     return new Promise((resolve, reject) => {
-      schematic.call(opts, host)
-        .map((tree: Tree) => Tree.optimize(tree))
-        .concatMap((tree: Tree) => {
+      schematic.call(opts, host).pipe(
+        map((tree: Tree) => Tree.optimize(tree)),
+        concatMap((tree: Tree) => {
           return dryRunSink.commit(tree).pipe(
             ignoreElements(),
             concat(observableOf(tree)));
-        })
-        .concatMap((tree: Tree) => {
+        }),
+        concatMap((tree: Tree) => {
           if (!error) {
             // Output the logging queue.
             loggingQueue.forEach(log => ui.writeLine(`  ${log.color(log.keyword)} ${log.message}`));
@@ -129,7 +129,7 @@ export default Task.extend({
           return fsSink.commit(tree).pipe(
             ignoreElements(),
             concat(observableOf(tree)));
-        })
+        }))
         .subscribe({
           error(err) {
             ui.writeLine(red(`Error: ${err.message}`));

packages/@angular/cli/tasks/schematic-run.ts

@@ -17,8 +17,6 @@ import {
   NodeModulesEngineHost
 } from '@angular-devkit/schematics/tools';
 import { SchemaClassFactory } from '@ngtools/json-schema';
-import 'rxjs/add/operator/concatMap';
-import 'rxjs/add/operator/map';
 
 const SilentError = require('silent-error');
 

packages/@angular/cli/utilities/schematics.ts

@@ -1,13 +1,13 @@
 import {LogEntry, Logger} from './logger';
 import {ConsoleLoggerStack} from './console-logger-stack';
 import {NullLogger} from './null-logger';
+import {toArray} from 'rxjs/operators';
 
 
 describe('ConsoleLoggerStack', () => {
   it('works', (done: DoneFn) => {
     const logger = ConsoleLoggerStack.start('test');
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([
@@ -26,8 +26,7 @@ describe('ConsoleLoggerStack', () => {
     const oldConsoleLog = console.log;
     const logger = ConsoleLoggerStack.start('test');
     expect(console.log).not.toBe(oldConsoleLog);
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([
@@ -55,8 +54,7 @@ describe('ConsoleLoggerStack', () => {
     const logger = new Logger('test');
     ConsoleLoggerStack.start(logger);
     expect(console.log).not.toBe(oldConsoleLog);
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([

packages/@ngtools/logger/src/console-logger-stack.spec.ts

@@ -1,12 +1,12 @@
 import {LogEntry, Logger} from './logger';
 import {IndentLogger} from './indent';
+import {toArray} from 'rxjs/operators';
 
 
 describe('IndentSpec', () => {
   it('works', (done: DoneFn) => {
     const logger = new IndentLogger('test');
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([

packages/@ngtools/logger/src/indent.spec.ts

@@ -1,7 +1,6 @@
+import { map } from 'rxjs/operators';
 import {Logger} from './logger';
 
-import 'rxjs/add/operator/map';
-
 
 /**
  * Keep an map of indentation => array of indentations based on the level.
@@ -18,20 +17,20 @@ export class IndentLogger extends Logger {
     super(name, parent);
 
     indentationMap[indentation] = indentationMap[indentation] || [''];
-    const map = indentationMap[indentation];
+    const indentMap = indentationMap[indentation];
 
-    this._observable = this._observable.map(entry => {
+    this._observable = this._observable.pipe(map(entry => {
       const l = entry.path.length;
-      if (l >= map.length) {
-        let current = map[map.length - 1];
-        while (l >= map.length) {
+      if (l >= indentMap.length) {
+        let current = indentMap[indentMap.length - 1];
+        while (l >= indentMap.length) {
           current += indentation;
-          map.push(current);
+          indentMap.push(current);
         }
       }
 
-      entry.message = map[l] + entry.message;
+      entry.message = indentMap[l] + entry.message;
       return entry;
-    });
+    }));
   }
 }

packages/@ngtools/logger/src/indent.ts

@@ -1,13 +1,11 @@
 import {Logger, JsonValue} from './logger';
-import 'rxjs/add/operator/toArray';
-import 'rxjs/add/operator/toPromise';
+import {toArray} from 'rxjs/operators';
 
 
 describe('Logger', () => {
   it('works', (done: DoneFn) => {
     const logger = new Logger('test');
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: JsonValue[]) => {
         expect(observed).toEqual([
@@ -25,8 +23,7 @@ describe('Logger', () => {
   it('works with children', (done: DoneFn) => {
     const logger = new Logger('test');
     let hasCompleted = false;
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: JsonValue[]) => {
         expect(observed).toEqual([

packages/@ngtools/logger/src/logger.spec.ts

@@ -1,12 +1,12 @@
 import {NullLogger} from './null-logger';
 import {LogEntry, Logger} from './logger';
+import {toArray} from 'rxjs/operators';
 
 
 describe('NullLogger', () => {
   it('works', (done: DoneFn) => {
     const logger = new NullLogger();
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([]);
@@ -20,8 +20,7 @@ describe('NullLogger', () => {
 
   it('nullifies children', (done: DoneFn) => {
     const logger = new Logger('test');
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([]);

packages/@ngtools/logger/src/null-logger.spec.ts

@@ -1,13 +1,10 @@
-import {Logger} from './logger';
-
-import {Observable} from 'rxjs/Observable';
-
-import 'rxjs/add/observable/empty';
+import { EmptyObservable } from 'rxjs/Observable/EmptyObservable';
+import { Logger } from './logger';
 
 
 export class NullLogger extends Logger {
   constructor(parent: Logger | null = null) {
     super('', parent);
-    this._observable = Observable.empty();
+    this._observable = new EmptyObservable();
   }
 }

packages/@ngtools/logger/src/null-logger.ts

@@ -1,22 +1,19 @@
 import {TransformLogger} from './transform-logger';
 import {LogEntry} from './logger';
-
-import 'rxjs/add/operator/filter';
-import 'rxjs/add/operator/map';
+import {filter, map, toArray} from 'rxjs/operators';
 
 
 describe('TransformLogger', () => {
   it('works', (done: DoneFn) => {
     const logger = new TransformLogger('test', stream => {
-      return stream
-        .filter(entry => entry.message != 'hello')
-        .map(entry => {
+      return stream.pipe(
+        filter(entry => entry.message != 'hello'),
+        map(entry => {
           entry.message += '1';
           return entry;
-        });
+        }));
     });
-    logger
-      .toArray()
+    logger.pipe(toArray())
       .toPromise()
       .then((observed: LogEntry[]) => {
         expect(observed).toEqual([

packages/@ngtools/logger/src/transform-logger.spec.ts

@@ -131,7 +131,6 @@ export default function () {
       'src/app/app.component.ts': `
         import { Component } from '@angular/core';
         import { Http, Response } from '@angular/http';
-        import 'rxjs/add/operator/map';
 
         @Component({
           selector: 'app-root',

tests/e2e/tests/basic/assets.ts

@@ -14,8 +14,7 @@ import * as path from 'path';
 import {setGlobalVariable} from './e2e/utils/env';
 
 // RxJS
-import 'rxjs/add/operator/filter';
-import 'rxjs/add/observable/empty';
+import {filter} from 'rxjs/operators';
 
 
 Error.stackTraceLimit = Infinity;
@@ -73,7 +72,7 @@ process.exitCode = 255;
 
 
 ConsoleLoggerStack.start(new IndentLogger('name'))
-  .filter((entry: LogEntry) => (entry.level != 'debug' || argv.verbose))
+  .pipe(filter((entry: LogEntry) => (entry.level != 'debug' || argv.verbose)))
   .subscribe((entry: LogEntry) => {
     let color: (s: string) => string = white;
     let output = process.stdout;

tests/e2e_runner.ts

@@ -5,7 +5,7 @@ import chalk from 'chalk';
 import * as minimist from 'minimist';
 
 
-import 'rxjs/add/operator/filter';
+import {filter} from 'rxjs/operators';
 
 
 const { bold, red, yellow, white } = chalk;
@@ -17,7 +17,7 @@ const argv = minimist(process.argv.slice(2), {
 const rootLogger = new IndentLogger('cling');
 
 rootLogger
-  .filter((entry: LogEntry) => (entry.level != 'debug' || argv['verbose']))
+  .pipe(filter((entry: LogEntry) => (entry.level != 'debug' || argv['verbose'])))
   .subscribe((entry: LogEntry) => {
     let color: (s: string) => string = white;
     let output = process.stdout;
@@ -32,7 +32,7 @@ rootLogger
   });
 
 rootLogger
-  .filter((entry: LogEntry) => entry.level == 'fatal')
+  .pipe(filter((entry: LogEntry) => entry.level == 'fatal'))
   .subscribe(() => {
     process.stderr.write('A fatal error happened. See details above.');
     process.exit(100);