Resultados de la búsqueda a petición "reactive-streams"
¿Cómo se usan las secuencias reactivas en Slick para insertar datos?
EnDocumentación de Slick [http://slick.typesafe.com/doc/3.1.1/dbio.html#streaming]Se presentan ejemplos de uso de flujos reactivos solo para leer datos como un medio de un publicador de bases de datos. Pero, ¿qué sucede cuando desea utilizar su ...
Mono vs Flux en flujo reactivo
Según la documentación: Flux es una corriente que puede emitir 0..N elementos: Flux<String> fl = Flux.just("a", "b", "c");Mono es una secuencia de 0..1 elementos: Mono<String> mn = Mono.just("hello");Y como ambas son implementaciones de ...
Cómo leer correctamente Flux <DataBuffer> y convertirlo en una sola entrada
Estoy usandoWebClient y personalizadoBodyExtractorclase para mi aplicación de arranque de primavera WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(MediaType.APPLICATION.XML) .exchange() .flatMap(response -> { ...
Implementación de Akka-Stream más lenta que la implementación de subproceso único
ACTUALIZACIÓN DE 2015-10-30 basado en Roland Kuhn Awnser: Akka Streams está utilizando mensajes asíncronos que pasan entre actores para implementar etapas de procesamiento de flujo. El paso de datos a través de un límite asincrónico tiene una ...
¿Cómo utilizar las secuencias reactivas para el procesamiento binario NIO?
¿Hay algunos ejemplos de código de usoorg.reactivestreams [http://www.reactive-streams.org/]bibliotecas para procesar grandes flujos de datos utilizando Java NIO (para un alto rendimiento)? Mi objetivo es el procesamiento distribuido, por lo que ...