wamr-98.ts

import { Observable } from 'rxjs';
import { retry } from 'rxjs/operators';

const observable = new Observable<number>(observer => {
  let x = 0;

  const interval = setInterval(() => {
    if (x === 5) {
      observer.error('Oops');
    }
    else {
      observer.next(x++);
    }
  }, 1000);

  return {
    unsubscribe: () => { console.log('clearing'); clearInterval(interval); }
  }
});

observable
  .pipe(
    retry(1)
  )
  .subscribe({
    next: x => console.log(`${x} received`),
    complete: () => console.log('Completed'),
    error: err => console.warn(err)
  });