RxJS - Délai d'expiration de l'opérateur utilitaire

Cet opérateur lèvera une erreur si la source Observable n'émet pas de valeur après le délai imparti.

Syntaxe

timeout(timeout: number | Date): Observable

Paramètres

timeout - L'entrée est le timeout qui peut être de type number ou Date dans lequel la valeur de la source Observable doit être émise.

Valeur de retour

Une observable est renvoyée qui s'arrêtera en fonction du délai imparti.

Exemple

import { of, interval } from 'rxjs';
import { filter, timeout } from 'rxjs/operators';
let list1 = interval(1000);
let final_val = list1.pipe(timeout(new Date("October 01, 2019 10:40:00")));
final_val.subscribe(
   x => console.log(x),
   e => console.log(e),
   () => console.log("Task complete")
);

L'intervalle observable continuera et le délai d'expiration sera donné comme nouvelle date ("01 octobre 2019 10:40:00"), donc à ce moment-là, le délai d'expiration se produira et il générera une erreur comme indiqué ci-dessous.

Production