Tag: RXJS-PIPEABLE-OPERATORS
Tengo la siguiente suscripción RxJS: combineLatest([obs1$, obs2$]) .pipe( filter(val=>!!val[0] && !!val[1]), // no valor nulo en ambos switchMap(([val1, val2]) => combineLatest([of(v1), getObs3$(v2)])) ) .subscribe(([val1, val3]) => { … }); El código funciona como se pretende, pero se siente complicado. Estoy bastante seguro de que se puede mejorar el switchMap en . . . Read more
Estoy utilizando el operador SwitchMap de RXJS en mi aplicación de Angular para cancelar las solicitudes anteriores, pero está cancelando las solicitudes si los parámetros de la consulta son diferentes. ¿Cómo podemos evitar cancelar solicitudes duplicadas anteriores si los parámetros de la solicitud son diferentes? @Effect() loadWeeklyForecastForLongRange$: Observable<loadweekforecastforlongrange |=”” action=””> . . . Read more
Estoy intentando intercambiar dos elementos en el array observable. Sé cómo hacerlo en el array normal. Intenté hacerlo de la misma manera pero no cambia el valor. Aquí está lo que intenté: swapObservableArray() { let index; // obtener el índice this.productss$ .pipe(findIndex((a) => a.id === 5)) .subscribe((a) => (index = . . . Read more
En nuestra aplicación Angular, usamos distinctUntilChanged() con bastante frecuencia y estamos en un punto en el que queremos usarlo para comparar directamente form.valueChanges. Como se describe en esta pregunta: https://stackoverflow.com/a/53825991/1003686, usar distinctUntilChanged en form.valueChanges no funcionará correctamente: this.myFormControl.valueChanges .pipe(distinctUntilChanged()) .subscribe(newValue => { console.log(‘se dispara infinitamente’); }); En cambio, tengo que . . . Read more
El tiempo de respuesta de la llamada a la API varía entre 2 y 30 segundos. Después de inicializar la llamada a la API, si la llamada a la API tardará más de cinco segundos, en el momento del sexto segundo, debo realizar alguna acción (ocultar el indicador) y la . . . Read more