feat(core): upgrade rxjs to 6.0.0-alpha.4 (angular#22573)

PR Close angular#22573

Author: IgorMinar

aio/content/examples/component-interaction/src/app/astronaut.component.ts

@@ -2,7 +2,7 @@
 import { Component, Input, OnDestroy } from '@angular/core';
 
 import { MissionService } from './mission.service';
-import { Subscription }   from 'rxjs/Subscription';
+import { Subscription }   from 'rxjs';
 
 @Component({
   selector: 'app-astronaut',

aio/content/examples/component-interaction/src/app/mission.service.ts

@@ -1,6 +1,6 @@
 // #docregion
 import { Injectable } from '@angular/core';
-import { Subject }    from 'rxjs/Subject';
+import { Subject }    from 'rxjs';
 
 @Injectable()
 export class MissionService {

aio/content/examples/hierarchical-dependency-injection/src/app/heroes-list.component.ts

@@ -1,6 +1,6 @@
 // #docregion
 import { Component }  from '@angular/core';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 
 import { Hero, HeroTaxReturn } from './hero';
 import { HeroesService }       from './heroes.service';

aio/content/examples/hierarchical-dependency-injection/src/app/heroes.service.ts

@@ -1,7 +1,6 @@
 import { Injectable } from '@angular/core';
 
-import { Observable } from 'rxjs/Observable';
-import { Observer } from 'rxjs/Observer';
+import { Observable, Observer } from 'rxjs';
 
 import { Hero, HeroTaxReturn } from './hero';
 

aio/content/examples/hierarchical-dependency-injection/src/app/villains-list.component.ts

@@ -1,6 +1,6 @@
 // #docregion
 import { Component }  from '@angular/core';
-import { Observable } from 'rxjs/Observable';
+import { Observable } from 'rxjs';
 
 import { Villain, VillainsService } from './villains.service';
 

aio/content/examples/hierarchical-dependency-injection/src/app/villains.service.ts

@@ -1,6 +1,6 @@
 import { Injectable } from '@angular/core';
 
-import { of }         from 'rxjs/observable/of';
+import { of }         from 'rxjs';
 
 export interface Villain { id: number; name: string; }
 

aio/content/examples/http/src/app/config/config.component.ts

@@ -30,7 +30,7 @@ export class ConfigComponent {
     this.configService.getConfig()
   // #enddocregion v1, v2
       .subscribe(
-        data => this.config = { ...data }, // success path
+        (data: Config) => this.config = { ...data }, // success path
         error => this.error = error // error path
       );
   }
@@ -39,7 +39,7 @@ export class ConfigComponent {
   showConfig_v1() {
     this.configService.getConfig_1()
   // #docregion v1, v1_callback
-      .subscribe(data => this.config = {
+      .subscribe((data: Config) => this.config = {
           heroesUrl: data['heroesUrl'],
           textfile:  data['textfile']
       });
@@ -51,7 +51,7 @@ export class ConfigComponent {
     this.configService.getConfig()
   // #docregion v2, v2_callback
       // clone the data object, using its known Config shape
-      .subscribe(data => this.config = { ...data });
+      .subscribe((data: Config) => this.config = { ...data });
   // #enddocregion v2_callback
   }
   // #enddocregion v2

aio/content/examples/http/src/app/config/config.service.ts

@@ -6,8 +6,7 @@ import { HttpClient } from '@angular/common/http';
 import { HttpErrorResponse, HttpResponse } from '@angular/common/http';
 
 // #docregion rxjs-imports
-import { Observable } from 'rxjs/Observable';
-import { ErrorObservable } from 'rxjs/observable/ErrorObservable';
+import { Observable, throwError } from 'rxjs';
 import { catchError, retry } from 'rxjs/operators';
 // #enddocregion rxjs-imports
 
@@ -82,8 +81,8 @@ export class ConfigService {
         `Backend returned code ${error.status}, ` +
         `body was: ${error.error}`);
     }
-    // return an ErrorObservable with a user-facing error message
-    return new ErrorObservable(
+    // return an observable with a user-facing error message
+    return throwError(
       'Something bad happened; please try again later.');
   };
   // #enddocregion handleError

aio/content/examples/http/src/app/heroes/heroes.service.ts

@@ -6,8 +6,7 @@ import { HttpHeaders } from '@angular/common/http';
 
 // #enddocregion http-options
 
-import { Observable } from 'rxjs/Observable';
-import { of } from 'rxjs/observable/of';
+import { Observable } from 'rxjs';
 import { catchError } from 'rxjs/operators';
 
 import { Hero } from './hero';

aio/content/examples/http/src/app/http-error-handler.service.ts

@@ -1,8 +1,7 @@
 import { Injectable } from '@angular/core';
 import { HttpErrorResponse } from '@angular/common/http';
 
-import { Observable } from 'rxjs/Observable';
-import { of } from 'rxjs/observable/of';
+import { Observable, of } from 'rxjs';
 
 import { MessageService } from './message.service';