Resultados de la búsqueda a petición "rxjs"
RxJS: ¿Cómo actualizaría "manualmente" un Observable?
Creo que debo estar malentendiendo algo fundamental, porque en mi opinión este debería ser el caso más básico para un observable, pero durante mi vida no puedo encontrar la manera de hacerlo a partir de los documentos. Básicamente, quiero poder ...
¿Cómo cargar RxJS en una aplicación mínima de Angular 2 usando systemjs?
No puedo obtener una aplicación mínima de Angular 2 usando RxJS desde el suelo. Estoy usando Typecript (tsc 1.6.2) y systemjs para cargar el módulo. ¿Cómo consigo systemjs para cargar el módulo Rx correctamente? Me he quedado sin ideas para ...
¿Cómo crear un búfer RxJS que agrupe elementos en NodeJS pero que no dependa del intervalo de ejecución permanente?
Estoy capturando eventos desde una aplicación usandoRx.Observable.fromEvent en un NodeJS. Estos se envían a otro servidor mediante solicitud ( https://www.npmjs.com/package/request [https://www.npmjs.com/package/request]) Para evitar una carga de ...
¿Por qué necesitamos usar flatMap?
Estoy empezando a usar RxJS y no entiendo por qué en este ejemplo necesitamos usar una función comoflatMap oconcatAll; ¿Dónde está la matriz de matrices aquí? var requestStream = Rx.Observable.just('https://api.github.com/users'); ...
Cómo iniciar el segundo observable * solo * después de que el primero se * complete * por completo en rxjs
Tenía la impresión de queObservable.[prototype.]concat se asegura de que la primera operación esté completamente terminada antes de que comience la segunda operación. Pero en el siguiente código: Observable ...
el observable de rxjs no se completa cuando se produce un error
Cuando creo un observable desde cero, y tengo el error del observador, luego completo, la parte completa de la suscripción nunca se invoca. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); ...
¿Cómo solicitar datos secuencialmente en Cycle.js?
Soy nuevo en la programación reactiva y jugando con cycle.js, tratando de implementar a quién seguir el cuadroeste tutorial [https://gist.github.com/staltz/868e7e9bc2a7b8c1f754]. Pero entendí que para una implementación adecuada (y para fines de ...
RxJS catch ** y ** reintenta un Observable
Mi caso de uso es mapear un Observable a acciones redux de éxito y fracaso. Realizo una llamada de red (con una función que promete), si tiene éxito, tengo que reenviar una acción de éxito, si falla, que una acción de error. El Observable mismo ...
La propiedad 'json' no existe en el tipo '{}'
Tengo una clase base abstracta en Typecript que se ve así: import {Http, Headers, Response} from 'angular2/http'; export abstract class SomeService { constructor(private http:Http) {} protected post(path:string, data:Object) { let ...
RxJS: concat tres promesas, distinguir resultados
Tengo tres promesas, Rest solicita que devuelvan listas de datos. El tercero tiene referencias (id) a las dos primeras listas, por lo que quiero asignar estos identificadores a los nombres correspondientes cuando tenga todos los datos. El mapeo ...