feat: update to rxjs 5.5.0 and switch to lettable operators

Bumps the required RxJS version to 5.5.0 and gets rid of our RxChain in favor of using the lettable Rx operators. Refactors all the usages and updates the configs.

Fixes #7275.

Author: crisbeto

.github/CODEOWNERS

@@ -48,7 +48,6 @@ src/lib/core/datetime/**           @mmalerba
 
 # CDK
 src/cdk/coercion/**                @jelbourn
-src/cdk/rxjs/**                    @jelbourn
 src/cdk/observers/**               @jelbourn @crisbeto
 src/cdk/collections/**             @jelbourn @crisbeto @andrewseguin
 src/cdk/a11y/**                    @jelbourn @devversion

CODING_STANDARDS.md

@@ -127,33 +127,20 @@ class ConfigBuilder {
 ```
 
 #### RxJS
-When dealing with RxJS operators, import the operator functions directly (e.g.
-`import "rxjs/operator/map"`), as opposed to using the "patch" imports which pollute the user's
-global Observable object (e.g. `import "rxjs/add/operator/map"`):
+When dealing with RxJS operators, import the lettable operator (e.g.
+`import {map} from 'rxjs/operators'`), as opposed to using the "patch" imports which pollute the
+user's global Observable object (e.g. `import 'rxjs/add/operator/map'`):
 
 ```ts
 // NO
 import 'rxjs/add/operator/map';
 someObservable.map(...).subscribe(...);
 
 // YES
-import {map} from 'rxjs/operator/map';
-map.call(someObservable, ...).subscribe(...);
+import {map} from 'rxjs/operators';
+someObservable.pipe(map(...)).subscribe(...);
 ```
 
-Note that this approach can be inflexible when dealing with long chains of operators. You can use
-the `RxChain` class to help with it:
-
-```ts
-// Before
-someObservable.filter(...).map(...).do(...);
-
-// After
-RxChain.from(someObservable).call(filter, ...).call(map, ...).call(do, ...).subscribe(...);
-```
-Note that not all operators are available via the `RxChain`. If the operator that you need isn't
-declared, you can add it to `/core/rxjs/rx-operators.ts`.
-
 #### Access modifiers
 * Omit the `public` keyword as it is the default behavior.
 * Use `private` when appropriate and possible, prefixing the name with an underscore.

package-lock.json

@@ -33,7 +33,7 @@
     "@angular/http": "~4.4.3",
     "@angular/platform-browser": "~4.4.3",
     "core-js": "^2.4.1",
-    "rxjs": "^5.0.1",
+    "rxjs": "5.5.0-beta.0",
     "systemjs": "0.19.43",
     "tsickle": "^0.23.5",
     "tslib": "^1.7.1",

package.json

@@ -20,7 +20,7 @@ import {
   SkipSelf,
 } from '@angular/core';
 import {Observable} from 'rxjs/Observable';
-import {of as observableOf} from 'rxjs/observable/of';
+import {of as observableOf} from 'rxjs/Observable/of';
 import {Subject} from 'rxjs/Subject';
 import {Subscription} from 'rxjs/Subscription';
 

src/cdk/a11y/focus-monitor.ts

@@ -17,7 +17,7 @@ import {
 } from '@angular/core';
 import {coerceBooleanProperty} from '@angular/cdk/coercion';
 import {Platform} from '@angular/cdk/platform';
-import {first} from '@angular/cdk/rxjs';
+import {first} from 'rxjs/operators';
 import {InteractivityChecker} from './interactivity-checker';
 
 
@@ -265,7 +265,7 @@ export class FocusTrap {
     if (this._ngZone.isStable) {
       fn();
     } else {
-      first.call(this._ngZone.onStable.asObservable()).subscribe(fn);
+      this._ngZone.onStable.asObservable().pipe(first()).subscribe(fn);
     }
   }
 }

src/cdk/a11y/focus-trap.ts

@@ -1,5 +1,5 @@
 import {DOWN_ARROW, TAB, UP_ARROW} from '@angular/cdk/keycodes';
-import {first} from '@angular/cdk/rxjs';
+import {first} from 'rxjs/operators';
 import {QueryList} from '@angular/core';
 import {fakeAsync, tick} from '@angular/core/testing';
 import {createKeyboardEvent} from '../testing/event-objects';
@@ -196,7 +196,7 @@ describe('Key managers', () => {
 
       it('should emit tabOut when the tab key is pressed', () => {
         let spy = jasmine.createSpy('tabOut spy');
-        first.call(keyManager.tabOut).subscribe(spy);
+        keyManager.tabOut.pipe(first()).subscribe(spy);
         keyManager.onKeydown(fakeKeyEvents.tab);
 
         expect(spy).toHaveBeenCalled();

src/cdk/a11y/list-key-manager.spec.ts

@@ -10,7 +10,7 @@ import {QueryList} from '@angular/core';
 import {Subject} from 'rxjs/Subject';
 import {Subscription} from 'rxjs/Subscription';
 import {UP_ARROW, DOWN_ARROW, TAB, A, Z, ZERO, NINE} from '@angular/cdk/keycodes';
-import {RxChain, debounceTime, filter, map, doOperator} from '@angular/cdk/rxjs';
+import {debounceTime, filter, map, tap} from 'rxjs/operators';
 
 /**
  * This interface is for items that can be passed to a ListKeyManager.
@@ -65,23 +65,24 @@ export class ListKeyManager<T extends ListKeyManagerOption> {
     // Debounce the presses of non-navigational keys, collect the ones that correspond to letters
     // and convert those letters back into a string. Afterwards find the first item that starts
     // with that string and select it.
-    this._typeaheadSubscription = RxChain.from(this._letterKeyStream)
-      .call(doOperator, keyCode => this._pressedLetters.push(keyCode))
-      .call(debounceTime, debounceInterval)
-      .call(filter, () => this._pressedLetters.length > 0)
-      .call(map, () => this._pressedLetters.join(''))
-      .subscribe(inputString => {
-        const items = this._items.toArray();
-
-        for (let i = 0; i < items.length; i++) {
-          if (items[i].getLabel!().toUpperCase().trim().indexOf(inputString) === 0) {
-            this.setActiveItem(i);
-            break;
-          }
+    this._typeaheadSubscription = this._letterKeyStream.pipe(
+      tap(keyCode => this._pressedLetters.push(keyCode)),
+      debounceTime(debounceInterval),
+      filter(() => this._pressedLetters.length > 0),
+      map(() => this._pressedLetters.join(''))
+    )
+    .subscribe(inputString => {
+      const items = this._items.toArray();
+
+      for (let i = 0; i < items.length; i++) {
+        if (items[i].getLabel!().toUpperCase().trim().indexOf(inputString) === 0) {
+          this.setActiveItem(i);
+          break;
         }
+      }
 
-        this._pressedLetters = [];
-      });
+      this._pressedLetters = [];
+    });
 
     return this;
   }

src/cdk/a11y/list-key-manager.ts

@@ -19,7 +19,7 @@ import {
   NgZone,
 } from '@angular/core';
 import {Subject} from 'rxjs/Subject';
-import {RxChain, debounceTime} from '@angular/cdk/rxjs';
+import {debounceTime} from 'rxjs/operators';
 
 /**
  * Factory that creates a new MutationObserver and allows us to stub it out in unit tests.
@@ -59,9 +59,8 @@ export class ObserveContent implements AfterContentInit, OnDestroy {
   ngAfterContentInit() {
     if (this.debounce > 0) {
       this._ngZone.runOutsideAngular(() => {
-        RxChain.from(this._debouncer)
-          .call(debounceTime, this.debounce)
-          .subscribe((mutations: MutationRecord[]) => this.event.emit(mutations));
+        this._debouncer.pipe(debounceTime(this.debounce))
+            .subscribe((mutations: MutationRecord[]) => this.event.emit(mutations));
       });
     } else {
       this._debouncer.subscribe(mutations => this.event.emit(mutations));