Estoy enfrentando un problema extraño y espero que alguien pueda arrojarme algo de luz.
Tengo una porción de mi estado que se actualiza en un intervalo (digamos cada 10 segundos por el bien de esta pregunta). Quiero suscribirme al selector para ese estado y el tiempo de espera si el estado no se actualiza para ese valor en X cantidad de tiempo. Estoy usando el operador de tiempo de espera rxjs para hacer esto.
@Select(MyState.myValue) myValue$: Observable<number>; setInterval(() => //updating MyState with a new myValue, 10000); myValue$ .pipe(timeout(20000)) .subscribe({ next: myValue => console.log(myValue), error: err => console.log(err) })Lo que estoy viendo es que TimeoutError se lanza después de 20 segundos, independientemente de la frecuencia con la que se emitan los valores.
SIN EMBARGO, el tiempo de espera SÍ funciona si solo lo aplico al Observable devuelto por la función de intervalo (). Con el siguiente código, nunca veo TimeoutError, que es lo que espero que suceda con el código anterior para NGXS.
interval(10000) .pipe(timeout(20000)) .subscribe({ next: myValue => console.log(intervalValue), error: err => console.log(err) })Entonces, ¿parece que hay algún problema con el Observable devuelto por el decorador Select?
al usar el operador de tiempo de espera, debe proporcionar una función de devolución de llamada a la propiedad with. de lo contrario, emite un TimeoutError ;
para su problema, también debe proporcionar un valor para cada parámetro. cada parámetro define el tiempo permitido entre cada valor empujado desde la fuente antes de que se agote el tiempo de espera del observable resultante
ejemplo =>
test$.pipe( timeout({ each: 1000, with: () => functionExecutedWithTimeout() }) )consulte la documentación oficial del operador de tiempo de espera para obtener más información
o puede usar debounceTime , es un operador rxjs y es más fácil
ejemplo
this.subject.pipe( debounceTime(500)) .subscribe({ next: myValue => //do anything, error: err => //do anything })recurso debounceTime