Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy buscando construir un pipeline de rxjs que emita el siguiente evento solo si el evento actual ha pasado por todo el pipeline (estructura FIFO). const { from } = rxjs; const { map, filter } = rxjs.operators; // el evento `2` solo debe ser emitido // cuando el evento . . . Read more
Estoy intentando actualizar un RxJS Subject a través del método de un componente. Pero no está sucediendo correctamente. cricketData$ = new Subject<string>(); ngOnChanges() { this.cricketData$ .asObservable() .pipe( tap(() => console.log( ‘Disparando llamada REST para la pestaña de cricket con el año’, this.year ) ), take(1) ) .subscribe(); this.cricketData$.next(‘sachin’); } updateCricketData() . . . Read more
Tengo 2 llamadas de servicio API que combino en un observable: const firstAPIrequest = this.firstApi.getData(); const secondAPIrequest = this.secondApi.getData(); const combined = zip(firstAPIrequest, secondAPIrequest); Actualmente los mapeo para devolver un array: combined.pipe( map((res) => { return [res[0], res[1]) //sólo un ejemplo } ); Luego lo uso como una suscripción en . . . Read more