Resultados de la búsqueda a petición "rxjs5"
Angular 2 RxJS Observable: Reintentar Cuando el filtro reintenta en estado de error
Estoy usando la biblioteca HTTP Angular 2 que devuelve un observable. Quiero implementar el reintento en cierto estado / código de error. Tengo un problema, si el error no es 429,Observable.of(error) se está ejecutando en caso de error para ...
Fork une dos observables de firebase
Estoy usando angular2fire. Estoy consultando e intentando obtener todos los tours desde una ciudad. getAllTours(cityId) { return this.af.database.list(`/cities/${cityId}/tours`) .map((tours): any => { tours.map((tour: any) => { tour.tour ...
Sentencia de mapa anidado de RxJS Refactor
Tengo un servicio que usa@angular/http para cargar datos de una API. Quiero crear una proyección de los datos recuperados para miComponents utilizando estos datos. Por eso escribí el siguiente código: getById(id: string) { return this.http ...
¿Cómo usar retryWhen con una función que devuelve un valor booleano?
Aquí está mi código: this._http.post(this._url_get + extension, '', { headers: headers }) .map(res => res['_body']) .retryWhen(errors => {return responseErrorProcess(errors)})ahora necesito tomar excepciones y pasarlas a miresponseErrorProcess() ...
SystemJS carga muchos archivos para rxjs
Tengo lo siguientesystemjs.config.js (basado en algún ejemplo que encontré en internet): (function (global) { System.config({ paths: { // paths serve as alias 'js:': 'js/', }, // map tells the System loader where to look for things map: { // ...
Devolución de llamada / enlace de la función "Cancelar suscripción" en la función "ejecutor" observable
Estoy confundido acerca de cuál es el propósito de la función "eliminar" o "cancelar suscripción", que (opcionalmente) se devuelve desde una función "ejecutor" observable, de la siguiente manera: const Rx = require('rxjs'); const obs = ...
¿Cómo depurar valores observables en Angular2 / Typecript?
He seguido el tutorial para angular 2 y tengo una funcionalidad de búsqueda que muestra una lista de héroes de forma asincrónica. <div *ngFor="let hero of heroes | async"> {{hero.name}} </div>En el componente tengo héroes observables: heroes: ...
Suscríbase a múltiples observables en Angular 2
Mi aplicación Angular 2 tiene 2 métodos [GetCategories () y GetCartItems ()] en un servicio, y ambos métodos devuelven Observables. Para invocar estos dos métodos uno tras otro desde mi componente, he escrito el siguiente código ngOnInit() { ...
rxjs 5 Publique Replay RefCount
No puedo entender comopublishReplay().refCount() trabajos. Por ejemplo (https://jsfiddle.net/7o3a45L1/ [https://jsfiddle.net/7o3a45L1/]): var source = Rx.Observable.create(observer => { console.log("call"); // expensive http request ...
Observable.forkJoin () no se ejecuta
Tengo el siguiente código: //Loop: For each user ID/Role ID, get the data userMeta.forEach((businessRole) => { Observable.forkJoin( af.database.object('/roles/'+businessRole.$value), af.database.object('/users/'+businessRole.$key) ).subscribe( ...