Resultados de la búsqueda a petición "reactive-programming"
Gestionar solicitudes idénticas con RxJava
Suponga que tengo un buscador que recupera una imagen de un enlace dado en un hilo separado. La imagen se almacenará en la memoria caché. Una vez que la imagen ya se almacena en caché, el buscador no volverá a buscar el enlace. El buscador es ...
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 ...
¿Por qué Spring ReactiveMongoRepository no tiene un método para guardar Mono?
Tengo un MovieRepository que extendió ReactiveMongoRepository. Quiero guardar un solo POJO de forma reactiva. Pero ReactiveMongoRepository no proporciona un método de guardado para Mono o Publisher. Tengo que usarblock() método o utilizar ...
RxJS: división de un resultado de matriz de Observable.fromPromise
Estoy usando RxJS aquí y parece que no puedo superar estoaparentemente Problema simple. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) { console.log('Next'); console.log(x); }, function error (x) ...
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 ...
Limitación de solicitudes concurrentes usando Rx y SelectMany
Tengo una lista de URL de páginas que quiero descargar simultáneamente usandoHttpClient. La lista de URL puede ser grande (¡100 o más!) Actualmente tengo este código: var urls = new List<string> { @"http:\\www.amazon.com", ...
Brillante: ¿cuál es la diferencia entre observeEvent y eventReactive?
Leí la documentación de Shiny sobre programación reactiva algunas veces, pero no puedo entender la diferencia entreobserveEvent yeventReactive. La documentación dice: Use observeEvent siempre que desee realizar una acción en respuesta a un ...
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 ...
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 ...