RxJS: tiempo de espera del operador de servicios públicos

Este operador arrojará un error si la fuente Observable no emite un valor después del tiempo de espera dado.

Sintaxis

timeout(timeout: number | Date): Observable

Parámetros

timeout - La entrada es el tiempo de espera que puede ser de tipo número o Fecha dentro del cual debe emitirse el valor de la fuente Observable.

Valor devuelto

Se devuelve un observable que se detendrá en función del tiempo de espera dado.

Ejemplo

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")
);

El intervalo observable continuará y el tiempo de espera se dará como una nueva Fecha ("01 de octubre de 2019 10:40:00"), por lo que en ese momento se producirá el tiempo de espera y arrojará un error como se muestra a continuación.

Salida