我正在迁移到[email protected]
并使用lettable运算符...我还更新了Observable
静态方法。我想知道Observable.throw
和import 'rxjs/add/observable/throw';
的对应物是什么。
我应该导入丑陋的_throw
吗?
import { _throw } from 'rxjs/observable/throw';
或者有更好的方法。老实说,我喜欢Observable
上的静态方法,现在似乎所有静态创建方法,如of
,from
都应该从rxjs/observable/<methodName>
导入?
我仍然在5.5左右,但它看起来像现在而不是导入throw使用ErrorObservable。
// import { _throw } from 'rxjs/observable/throw';
import { ErrorObservable } from 'rxjs/observable/ErrorObservable';
ErrorObservable.create('error');
从这个guide看起来它必须是_throw以避免关键字冲突(视频的其余部分适合5.5入门)
继续Mick的回答,在rxjs版本6中_throw
被throwError
取代
import {Observable, throwError} from 'rxjs';
是的_throw
是正确的(这将完成JayChase所写的,但代码较少)。你对of
做同样的事情:
import {of} from 'rxjs/observable/of';
import {_throw} from 'rxjs/observable/throw';
// ...
// ...
if (result) {
return of(result as T);
} else {
return _throw('error');
}
}
对于Angular 5及以上版本:
import{Http} from '@angular/http';
import {HttpClient,HttpResponse,HttpErrorResponse } from '@angular/common/http';
import { Injectable} from '@angular/core'
import {Employee} from './employee';
import { Observable,throwError } from 'rxjs';
import { map,catchError } from 'rxjs/operators';
@Injectable()
export class employeeService{
constructor(private _http:Http){ }
getEmployees():Observable<Employee[]>{
return this._http.get('YOUR URL')
.pipe(
map((res: Response) => res.json()),
catchError(this.handleError)
);
//.pipe(catchError(this.handleError));
}
handleError(error:HttpErrorResponse){
console.log(error);
return throwError(error.message);
}
}
如果你想知道使用哪一个 - ErrorObservable vs _throw,这里是来自5.5.2源核心的东西
RxJs library 5.5.2 - throw.ts file
import { ErrorObservable } from './ErrorObservable';
export const _throw = ErrorObservable.create;
所以,没关系。