Блог

Возможно, я упускаю суть, но у меня создалось впечатление, что observer.complete() завершит observer, т.Е. Операторы после 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();
     });
   }
 }
  

Я могу правильно видеть консоль, но подписчик получает данные и null. Как я могу это сделать? Я ожидал получить данные через observer.next(data), а observer.next(null) не будет выполнен, поскольку я ранее вызывал observer.complete() .

Теперь я сначала получаю данные, а затем null, чего я не ожидал

Никакие другие значения не будут выдаваться наблюдателем после его завершения.

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) позже, но observer уже завершен.