Resultados de la búsqueda a petición "reactive-programming"
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 ...
Encadenamiento de observables RxJs en Angular 2
Tengo una función TypeScript en mi aplicación Angular 2 que devuelve un Observable, para enviar los datos de la API web al consumidor, algo como esto: public getApiData(): Observable { let readySource = Observable.from('no', 'no', 'ready'); let ...
Encadenamiento de observables en RxJS
Estoy aprendiendo RxJS y Angular 2. Digamos que tengo una cadena de promesa con múltiples llamadas a funciones asíncronas que dependen del resultado anterior, que se ve así: var promiseChain = new Promise((resolve, reject) => { setTimeout(() => ...
RxJava reintenta cuando hay un comportamiento extraño
Estoy jugando con el RxJavareintentarCuando [http://reactivex.io/documentation/operators/retry.html]operador. Se encuentra muy poco al respecto en Internet, el único digno de mención ...
Rxjs: consume la salida de la API y vuelve a consultar cuando el caché está vacío
Estoy tratando de implementar una versión deesta introducción a RxJS [https://xgrommx.github.io/rx-book/content/guidelines/introduction/index.html] ( violín aquí [http://jsfiddle.net/staltz/8jFJH/48/]) que en lugar de elegir un objeto aleatorio ...
capas dinámicas de ggplot en brillante con nearPoints ()
Estoy familiarizado con los conceptos básicos de brillante pero luchando con algo aquí. Me gustaría poder agregar una capa ggplot cuando se hace clic en un punto para resaltar ese punto. Sé que esto es posible con ggvis y hay un buen ejemplo en ...
Cómo combinar 3 observables de firebase sin perder actualizaciones dinámicas
Tengo una base de fuego paralela 3 requiere. Y necesito unirme a ellos como un solo objeto. Código de la siguiente manera: import {Http} from "@angular/http"; import {AngularFireDatabase} from "angularfire2"; import {Thread} from ...
R Error de reactividad de entrada brillante al arrastrar y soltar
Actualmente estoy creando una aplicación R Shiny con algunos js personalizados para proporcionar la funcionalidad de arrastrar y soltar. Mientras que arrastrar y soltar funciona perfectamente para un solo archivo, cuando lo restablezco usando ...
¿Suscribirse con Vs suscribirse en RxJava2 (Android)?
¿Cuándo llamar al método subscribeWith en lugar de simple suscribirse? ¿Y cuál es el caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
Apache Kafka Streams Materializing KTables a un tema parece lento
Estoy usando kafka stream y estoy tratando de materializar una tabla K en un tema. Funciona pero parece que se hace cada 30 segundos más o menos. ¿Cómo / cuándo Kafka Stream decide materializar el estado actual de una KTable en un tema? ¿Hay ...