升級到Angular6后對老版本的RXJS代碼做相應的調整

還沒有了解過RXJS6的童鞋，可以查看我的另外一篇博文，此篇博文主要是對於RXJS5升級到RXJS6的代碼調整示例

RXJS5版本

在RXJS5上我們是這樣寫請求的

import 'rxjs/add/observable/of';
import 'rxjs/add/observable/throw';
import 'rxjs/add/observable/map';
import 'rxjs/add/observable/mergemap';

this.http
    .get<{id: number; userId: number; title: string; body: string}[]>(
        'http://...........'
    )
    .map(data => {
            return ......;
    })
    .catch(error => {
        .....
    })
    .subscrible(...)

RXJS6對應修改為：

import {HttpClient} from '@angular/common/http';
import {Observable, of, throeError} from 'rxjs';
import {map, catchError} from 'rxjs';

 

this.http
    .get<{id: number; userId: number; title: string; body: string}[]>(
        'http://...........'
    )
    .pipe(
        map(data => {
            return ......;
        }),
        catchError(error => {
            return throwError('.....');
        })
    )
    .subscrible(...)