Resultados de la búsqueda a petición "rxjs"

3 la respuesta

Operador angular de 6 tubos RxJs para encadenar 3 observables dependientes

Tengo 3 recursos dependientes de la API Rest (digamos observables) como este: 1st observable produce un elemento como conjunto de usuarios, como este: getUsers(): Observable<User[]> [ { "id": 1, "name": "Peter", "surname": "Smith" }, { "id": ...

1 la respuesta

Angular: AgGrid no actualizará filas cuando se suscriba a Observable

Estoy tratando de incorporar rxjs y observables en la grilla ag. Para practicar, estoy siguiendo un ejemplo oficial de ag grid:https: //www.ag-grid.com/javascript-grid-rxjs [https://www.ag-grid.com/javascript-grid-rxjs/] Actualmente estoy ...

2 la respuesta

Creación de un canal de comunicación entre componentes en Angular

Así que tengo dos componentes, CompA y compA5, que están separados por 3 o 4 niveles, quiero crear un canal de comunicación entre los componentes. Digamos que desde el componente CompA quiero enviar un evento a compA5 para devolver algunos ...

2 la respuesta

tap () no se activa en RXJS Pipe

Tengo que hacer lo mismo, aunque prefiero el primero. Pero el primer enfoque no parece funcionar. (eltap() no se activa) // does not work this.actions$.pipe( ofType(LayoutActions.Types.CHANGE_THEME), takeUntil(this.destroyed$), tap(() => { ...

0 la respuesta

RxJs Ramificación si otra lógica

onSave() { // event handler const save$ = combineLatest(this.configData.data, this.layerService.layerData) .pipe( filter(([configData]) => !_.isEmpty(configData)), take(1), tap(_ => this.loadingService.showLoading()), map(data => ...

1 la respuesta

Cómo crear un http observable que haga solicitudes dinámicas

Tengo un observable que hace solicitudes dinámicas. Por ejemplo getFlowers(params?: any): Obeservable<Flower[]> { return this.http.get<Flower[]>( `http://flowers.com/flowers`, { params } ) } Ahora, la función anterior devuelve una nuevahttp ...

1 la respuesta

¿Por qué switchMap no cancela al observador anterior?

Tengo el método descrito en el componente (controlador): public requestPassportData(): void { const th = this; const data = { get_scanned_data: true }; Observable.timer(0, 1000) .switchMap(() => this.requestMethods.requestPassportData(data)) ...