首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >TypeError:在应为流的位置提供了无效的对象。您可以提供Observable、Promise、Array或Iterable

TypeError:在应为流的位置提供了无效的对象。您可以提供Observable、Promise、Array或Iterable
EN

Stack Overflow用户
提问于 2017-04-22 01:59:36
回答 21查看 224.9K关注 0票数 91

我正在尝试从一个服务调用map,但得到一个错误。看看subscribe is not defined in angular 2?,它说为了订阅,我们需要从运算符内部返回。我也有返回语句。

下面是我的代码:

代码语言:javascript
复制
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:在需要流的位置提供了无效的对象。您可以提供可观察、可承诺、可数组或可迭代的

EN

回答 21

Stack Overflow用户

发布于 2018-07-23 16:18:23

在我的例子中,错误只发生在e2e测试期间。它是由我AuthenticationInterceptor中的throwError引起的。

我从错误的来源导入了它,因为我使用了WebStorm的导入功能。我使用的是RxJS 6.2。

错误:

代码语言:javascript
复制
import { throwError } from 'rxjs/internal/observable/throwError';

正确:

代码语言:javascript
复制
import { throwError } from 'rxjs';

截取程序的完整代码如下:

代码语言:javascript
复制
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);
        })
     );
  }
}
票数 44
EN

Stack Overflow用户

发布于 2017-04-22 02:11:46

在您的示例代码中,您让map操作符接收两个回调,而实际上它应该只接收一个。您可以将错误处理代码移到catch回调中。

代码语言:javascript
复制
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);
                       })
   }

您还需要导入catchthrow操作符。

代码语言:javascript
复制
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';

编辑:请注意,通过在捕获处理程序中返回Observable.throw,您实际上不会捕获错误-它仍然会浮出控制台。

票数 21
EN

Stack Overflow用户

发布于 2018-02-06 07:00:45

如果您的函数期望返回一个布尔值,只需执行以下操作:

  1. Import:

代码语言:javascript
复制
import { of, Observable } from 'rxjs';
import { map, catchError } from 'rxjs/operators';

  1. Then

代码语言:javascript
复制
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);
      })
)}
票数 10
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/43549223

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档