Zauważalne wreszcie po zasubskrybowaniu

Zgodnie z tym artykułem , onCompletea onErrorfunkcje tych elementów subscribewzajemnie się wykluczają.

Czyli albo onErrorczy onCompleteimprezy będzie ogień w moim subscribe.
Mam blok logiczny, który musi zostać wykonany, niezależnie od tego, czy otrzymam błąd, czy pomyślnie zakończę przesyłanie informacji.

Szukałem czegoś podobnego finallydo Pythona , ale znalazłem tylko to, finallyco musi być dołączone do obserwowalnego, który tworzę.

Ale chcę postępować zgodnie z tą logiką tylko wtedy, gdy subskrybuję i po zakończeniu transmisji, czy to pomyślnie, czy z błędem.

Jakieś pomysły?

Obecny wariant „pipable” tego operatora jest nazywany finalize()(od RxJS 6). Został wywołany starszy i obecnie przestarzały operator „łatki” finally()(do wersji RxJS 5.5).

Myślę, że finalize()operator jest rzeczywiście poprawny. Mówisz:

stosuję tę logikę tylko wtedy, gdy subskrybuję i po zakończeniu transmisji

co nie jest moim zdaniem problemem. Możesz mieć jeden sourcei użyć go finalize()przed zapisaniem się, jeśli chcesz. W ten sposób nie musisz zawsze używać finalize():

let source = new Observable(observer => {
  observer.next(1);
  observer.error('error message');
  observer.next(3);
  observer.complete();
}).pipe(
  publish(),
);

source.pipe(
  finalize(() => console.log('Finally callback')),
).subscribe(
  value => console.log('#1 Next:', value),
  error => console.log('#1 Error:', error),
  () => console.log('#1 Complete')
);

source.subscribe(
  value => console.log('#2 Next:', value),
  error => console.log('#2 Error:', error),
  () => console.log('#2 Complete')
);

source.connect();

To drukuje do konsoli:

#1 Next: 1
#2 Next: 1
#1 Error: error message
Finally callback
#2 Error: error message

Sty 2019: Zaktualizowano dla RxJS 6

Jedyna rzecz, która mi pomogła, to to

fetchData()
  .subscribe(
    (data) => {
       //Called when success
     },
    (error) => {
       //Called when error
    }
  ).add(() => {
       //Called when operation is complete (both success and error)
  });

Teraz używam RxJS 5.5.7 w aplikacji Angular i finalizeoperator using ma dziwne zachowanie dla mojego przypadku użycia, ponieważ jest uruchamiany przed pomyślnym wywołaniem zwrotnym lub błędem.

Prosty przykład:

// Simulate an AJAX callback...
of(null)
  .pipe(
    delay(2000),
    finalize(() => {
      // Do some work after complete...
      console.log('Finalize method executed before "Data available" (or error thrown)');
    })
  )
  .subscribe(
      response => {
        console.log('Data available.');
      },
      err => {
        console.error(err);
      }
  );

Musiałem użyć addmedhod w subskrypcji, aby osiągnąć to, czego chcę. Zasadniczo finallywywołanie zwrotne po pomyślnym lub błędnym wywołaniu zwrotnym. Jak try..catch..finallyblok lub Promise.finallymetoda.

Prosty przykład:

// Simulate an AJAX callback...
of(null)
  .pipe(
    delay(2000)
  )
  .subscribe(
      response => {
        console.log('Data available.');
      },
      err => {
        console.error(err);
      }
  );
  .add(() => {
    // Do some work after complete...
    console.log('At this point the success or error callbacks has been completed.');
  });