Articles of rxjs5

RxJS: takeUntil () componente angular ngOnDestroy ()

tl; dr: Básicamente quiero casarme con ngOnDestroy de ngOnDestroy con el operador takeUntil() . — ¿es eso posible? Tengo un componente angular que abre varias suscripciones Rxjs. Estos deben estar cerrados cuando se destruye el componente. Una solución simple para esto sería: class myComponent { private subscriptionA; private subscriptionB; private subscriptionC; constructor( private serviceA: ServiceA, […]

¿Cómo forzar a los observables a ejecutarse en secuencia?

Me estoy moviendo del mundo Promesa al mundo Observable. Una cosa que suelo hacer con Promise es encadenar una serie de tareas y hacerlas ejecutar en secuencia. Por ejemplo, tengo tres tareas: printLog1() para imprimir 1 en la consola, printLog23() para imprimir 2 y 3 en la consola e printLog4() para imprimir 4. Cuando quiero […]

Angular 2 usando RxJS – toma (1) frente a la primera ()

Encontré poca implementación de Auth Guards que usa take(1) . En mi proyecto, utilicé first() para satisfacer mis necesidades. ¿Funciona de la misma manera? O uno de ellos podría tener ventajas más o menos. import ‘rxjs/add/operator/map’; import ‘rxjs/add/operator/first’; import { Observable } from ‘rxjs/Observable’; import { Injectable } from ‘@angular/core’; import { CanActivate, Router, ActivatedRouteSnapshot, […]

No se puede manejar correctamente el error en ajax de rxjs

Escribo la aplicación en Reaccionar un Redux y tengo un caso en el que tengo que enviar la solicitud a algún recurso cuando se solicitó una acción específica y una respuesta de tipo ‘text/html’ escribe en estado. Este recurso puede devolver el estado 200 o 404, y no puedo escribir la prueba correcta para el […]

Angular2 + http en un intervalo

Soy bastante nuevo en angular y rxjs. Intento crear una aplicación angular2 que obtenga algunos datos del archivo de texto servido de forma estática (localmente en el servidor), que me gustaría recuperar y asignar a Datamodel usando el proveedor http de Angular2 y el mapa de rxjs en un interval(5000) tiempo fijo interval(5000) . Para […]

¿Cuál es la forma correcta de compartir el resultado de una llamada de red de Hngp angular en RxJs 5?

Al usar Http, llamamos a un método que realiza una llamada de red y devuelve un http observable: getCustomer() { return this.http.get(‘/someUrl’).map(res => res.json()); } Si tomamos esto observable y agregamos varios suscriptores a él: let network$ = getCustomer(); let subscriber1 = network$.subscribe(…); let subscriber2 = network$.subscribe(…); Lo que queremos hacer es asegurarnos de que […]