ssougnez

function foo() {
  console.log('Hello');

  bar();
}

function bar() {
  console.log('Good bye')
}

ssougnez

import { Observable } from 'rxjs';
import { delay, retryWhen } from 'rxjs/operators';

observable
  .pipe(
    retryWhen(errors => errors.
      pipe(
        delay(2500)
      )
    )

ssougnez

import { interval, Observable } from 'rxjs';
import { retryWhen } from 'rxjs/operators';

observable
  .pipe(
    retryWhen(errors => interval(2500))
  )
  .subscribe({
    next: x => console.log(`${x} received`),
    complete: () => console.log('Completed'),

ssougnez

import { Observable } from 'rxjs';
import { retryWhen, take } from 'rxjs/operators';

observable
  .pipe(
    retryWhen(errors => errors.pipe(take(2)))
  )
  .subscribe({
    next: x => console.log(`${x} received`),
    complete: () => console.log('Completed'),

ssougnez

import { Observable } from 'rxjs';
import { retryWhen, tap } from 'rxjs/operators';

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

  const interval = setInterval(() => {
    if (x === 5) {
      observer.error('Oops');
    }

ssougnez

import { Observable, of, throwError } from 'rxjs';
import { catchError, finalize, map } from 'rxjs/operators';

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

  const interval = setInterval(() => {
    if (x === 0) {
      observer.error('Oops');
    }

ssougnez

import { Observable, of } from 'rxjs';
import { catchError, finalize } from 'rxjs/operators';

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

  const interval = setInterval(() => {
    if (x === 5) {
      observer.error('Oops');
    }

ssougnez

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');
    }

ssougnez

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

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

  const interval = setInterval(() => {
    if (x === 5 && Math.random() < .5) {
      observer.error('Oops');
    }

ssougnez

import { Observable, throwError } from 'rxjs';
import { catchError } from 'rxjs/operators';

observable
  .pipe(
    catchError(err => {
      console.warn('I want to display this error globally');
      
      return throwError(err);
    })