Resultados de la búsqueda a petición "reactive-programming"
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 ...
Spring 5 Web Reactive - ¿Cómo podemos usar WebClient para recuperar datos transmitidos en un Flux?
La documentación actual de hitos (M4) muestra un ejemplo sobre cómo recuperar unMono utilizandoWebClient: WebClient webClient = WebClient.create(new ReactorClientHttpConnector()); ClientRequest<Void> request ...
Rxjs: ¿cómo puedo extraer múltiples valores dentro de una matriz y retroalimentarlos a la secuencia observable sincrónicamente?
He creado unRx.Observable de una secuencia de eventos: Rx.Observable.fromEvent(recognizeStream, 'data')En el que cada evento de datos se ve así: { error: null, alternatives: [result1, result2, result3] }Quiero extraer todos los valores dentro ...
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 ...
Cómo convertir o asignar fácilmente un observable a un sujeto de comportamiento, para que otro componente pueda compartirlo
Soy nuevo en la programación de estilo Observable. Tengo una pregunta: quiero compartir información de usuario en la aplicación entre componentes, y uso BehaviorSubject para compartir esta información. Esto se inspira al compartir BehaviorSubject ...
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 ...
¿Cómo “gestionas” realmente el número máximo de hilos web utilizando la Programación Reactiva de Spring 5?
Al usar un enfoque clásico de Tomcat, puede darle a su servidor un número máximo de hilos que puede usar para manejar las solicitudes web de los usuarios. Usando el paradigma de Programación Reactiva y Reactor en Spring 5, podemos escalar mejor ...
¿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()) ...
RxJS takeWhile pero incluye el último valor
Tengo una tubería RxJS5 que se ve así Rx.Observable.from([2, 3, 4, 5, 6]) .takeWhile((v) => { v !== 4 })Quiero mantener la suscripción hasta que vea 4, pero quiero que el último elemento 4 también se incluya en el resultado. Entonces el ejemplo ...
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 ...