【问题标题】:observer.complete() not returning immediatelyobserver.complete() 没有立即返回
【发布时间】:2019-04-14 15:32:10
【问题描述】:

也许我没有抓住重点,但我的印象是observer.complete() 会完成观察者,即observer.complete() 之后的语句在完成后不会执行。

 export class RecordsService {
   public getRecords(): Observable<any> {

let vm = this;

return new Observable(observer => {
    var records = vm.http.get(
    url).subscribe(data =>{
      console.log('we got data ', data);
      observer.next(data)
      observer.complete();
    });

    observer.next(null);
    observer.complete();
     });
   }
 }

我可以正确看到控制台,但订阅者正在获取数据并且为空。我怎样才能做到这一点?我希望通过observer.next(data) 获取数据,并且observer.next(null) 不会被执行,因为我之前调用了observer.complete()。

现在我先得到数据,然后是 null,这是我没想到的

【问题讨论】:

  • 您期望的行为是什么? observer 是什么?
  • @alt255 也许我的解释错了,但是observer.next(data); observer.complete() 会因为没有更好的词而停止进一步的执行。没想到调用observer.complete()后会返回null。

标签: angular


【解决方案1】:

观察者完成后不会发出其他值。

https://stackblitz.com/edit/typescript-4cc25g

import { Observable } from 'rxjs';

const hello = Observable.create(function(observer) {
  observer.next('Hello');
  observer.complete();
  observer.next('World');
});

const subscribe = hello.subscribe(val => console.log(val));

您可以在 stackblitx 示例中看到这一点。

我希望通过observer.next(data) 获取数据,并且observer.next(null) 不会被执行,因为我之前调用了observer.complete()。

observer.next(null) 被调用首先,异步 HTTP 稍后调用observer.next(data),但观察者已经完成。

【讨论】:

  • 感谢@cgTag。查看我的代码,只有在没有发送数据的情况下才能让 null 稍后发送?
  • @NieSelam 这取决于没有数据发送的方式。是 HTTP 错误的结果还是 HTTP 响应不包含数据?
  • @Reactgular 我们可以在不发出任何值的情况下完成吗.next 我可以在我的代码仓库中看到很多地方 takeUntill(this.destroyed$) this.destroyed$.next(true); this.destroyed$.complete();
猜你喜欢
  • 2014-01-14
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2023-03-31
  • 2021-08-07
  • 2010-10-14
  • 2012-07-11
  • 1970-01-01
相关资源
最近更新 更多