我试图映射从服务调用，但得到一个错误。看了订阅没有在角2中定义？它说为了订阅，我们需要从运算符内部返回。我也有返回语句。
这是我的代码：
checkLogin(): Observable<boolean> {
return this.service
.getData()
.map(
(response) => {
this.data = response;
this.checkservice = true;
return true;
},
(error) => {
// debugger;
this.router.navigate(["newpage"]);
console.log(error);
return false;
}
)
.catch((e) => {
return e;
});
}
错误日志：
TypeError：您提供了一个无效的对象，其中需要流。您可以提供可观察、promise、数组或迭代
在我的例子中，错误仅发生在e2e测试期间。它是由我的AuthenticationInterceptor中的throwError引起的。
我从错误的来源导入了它，因为我使用了WebStorm的导入功能。我正在使用RxJS 6.2。
错误：
import { throwError } from 'rxjs/internal/observable/throwError';
正确：
import { throwError } from 'rxjs';
这里是拦截器的完整代码：
import { Injectable } from '@angular/core';
import { HttpErrorResponse, HttpEvent, HttpHandler, HttpInterceptor, HttpRequest } from '@angular/common/http';
import { Observable, throwError } from 'rxjs';
import { catchError } from 'rxjs/operators';
@Injectable()
export class AuthenticationInterceptor implements HttpInterceptor {
intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
const reqWithCredentials = req.clone({withCredentials: true});
return next.handle(reqWithCredentials)
.pipe(
catchError(error => {
if (error.status === 401 || error.status === 403) {
// handle error
}
return throwError(error);
})
);
}
}
在您的示例代码中，您的map运算符接收了两个回调，而它应该只接收一个。您可以将错误处理代码移动到catch回调。
checkLogin():Observable<boolean>{
return this.service.getData()
.map(response => {
this.data = response;
this.checkservice=true;
return true;
})
.catch(error => {
this.router.navigate(['newpage']);
console.log(error);
return Observable.throw(error);
})
}
您还需要导入catch和抛出运算符。
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';
编辑：请注意，通过在catch处理程序中返回可观察的，您实际上不会捕获错误-它仍然会出现在控制台。
如果您的函数期望返回布尔值，只需执行以下操作：
import { of, Observable } from 'rxjs';
import { map, catchError } from 'rxjs/operators';
checkLogin(): Observable<boolean> {
return this.service.getData()
.pipe(
map(response => {
this.data = response;
this.checkservice = true;
return true;
}),
catchError(error => {
this.router.navigate(['newpage']);
console.log(error);
return of(false);
})
)}
