Resultados de la búsqueda a petición "rxjs"
El servicio Angular2 Observable BehaviorSubject no funciona
Estoy tratando de crear mi propio servicio observable, pero después de obtener los datos iniciales del servicio, las actualizaciones del servicio no se propagan a ningún suscriptor. El servicio se ve así: import { Injectable } from ...
faltan flatMap después de actualizar a RC 6 y RxJS Beta 11
Después de actualizar a RC6 y [email protected], parece que me faltan algunas extensiones del objeto Observable. El operador flatMap se ha ido, mergeMap tampoco está aquí. Ahora solo veo algunos operadores. ¿Alguna idea de lo que me estoy ...
Paquete Angular2 2.0.xy Rx 5 beta.12
Actualmente estoy actualizando las dependencias de mi proyecto que usa los paquetes Angular2 npm y, por lo tanto, también RxJs. Estoy actualizando a la versión 2.0.2 estable de angular que depende de Rx5 beta.12. Para mi aplicación web, solo ...
Cómo devolver un observable vacío en rxjs
La funciónmore() se supone que debe devolver unObservable de una solicitud de obtención export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } ...
¿Cómo utilizar el operador Rx.Observable.prototype.let?
El ejemplo y explicación de lalet operador ( https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/let.md [https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/let.md] ) no está claro. Alguien ...
ForkJoin 2 BehaviorSubjects
Tengo dos secuencias de temas de comportamiento que intento bifurcar sin suerte. Como me imaginé, me devuelve los dos últimos valores. ¿Es esto posible implementarlo de alguna manera? No se llama después del tema. let stream1 = new ...
Cómo volver observable desde suscribirse
Estoy tratando de devolver un observable cuando obtengo un cierto valor en un suscriptor, pero fallo miserablemente. Este es el código: canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable<boolean> { // get route to ...
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 ...
angular2 / RxJS: cómo volver a intentarlo desde el interior subscribe ()
Este es mi código: this._api.getCompanies().subscribe( res => this.companies = JSON.parse(res), exception => {if(this._api.responseErrorProcess(exception)) { // in case this retured TRUE then I need to retry() } } )en caso de que ocurra una ...
¿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() ...