Resultados de la búsqueda a petición "reactive-programming"
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: ¿Cómo hacer un bucle en función del estado de lo observable?
Estoy tratando de hacer que RxJs se repita en un Observable en mi transmisión hasta que esté en un cierto estado, luego haga que la transmisión continúe. Específicamente, estoy convirtiendo un bucle sincrónico do / while a RxJs, pero supongo que ...
Falta inexplicable de mejora del rendimiento utilizando RxJava Observables en aplicaciones web
Estoy realizando algunas pruebas para evaluar si hay una ventaja real en el uso de API reactivas basadas en Observables, en lugar de bloquear las tradicionales. Todo el ejemplo esdisponible en ...
Creación dinámica de pestañas con trazados brillantes sin volver a crear pestañas existentes
Me gustaría crear pestañas dinámicas, donde cada vez que el usuario haga clic en un botón, se creará una nueva pestaña. Cada pestaña tiene el mismo contenido, con una variedad de widgets que el usuario puede usar para seleccionar qué conjuntos de ...
Llamar a setState en render no es evitable
Reaccionar documento afirma que elrender la función debe serpurolo que significa que no debería usarthis.setState en él. Sin embargo, creo que cuando el estado depende de 'remoto', es decir, resultado de una llamada ajax. La única ...
Cuándo cancelar una suscripción
Tengo una pregunta sobre cómo cancelar la suscripción de un observable. Tengo dos códigos y no estoy seguro de cuál es mejor. Ejemplo 1 -> Darse de baja del suscriptor una vez que la transmisión haya finalizado: Subscriber<String> subscriber = ...
¿Cómo usar Observable.fromCallable () con una excepción marcada?
Observable.fromCallable() es ideal para convertir una sola función en un Observable. Pero, ¿cómo maneja las excepciones marcadas que podría generar la función? La mayoría de los ejemplos que he visto usan lambdas y "simplemente funcionan". ¿Pero ...
Obtenga el último valor de un Observable y emítalo inmediatamente
Estoy tratando de obtener el último valor de un determinadoObservable y hacer que se emita inmediatamente una vez que se llame. Dado el siguiente código como ejemplo: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { ...
RxJS espera hasta que se resuelva la promesa
Todavía estoy descubriendo la programación reactiva, así que estoy bastante seguro de que esto es muy básico, pero la cantidad de transformaciones de flujo es bastante abrumadora para un principiante. Estoy creando un Observable a partir de un ...