Resultados da pesquisa a pedido "reactive-streams"
Como usar fluxos reativos para processamento binário de NIO?
Existem alguns exemplos de código de usoorg.reactivestreams [http://www.reactive-streams.org/]bibliotecas para processar grandes fluxos de dados usando Java NIO (para alto desempenho)? Meu objetivo é o processamento distribuído, então exemplos ...
Implementação do Akka-Stream mais lenta que a implementação de thread único
ATUALIZAÇÃO DE 30-10-2015 baseado em Roland Kuhn Awnser: O Akka Streams está usando a passagem assíncrona de mensagens entre os atores para implementar estágios de processamento do fluxo. A passagem de dados através de um limite assíncrono tem ...
Como os fluxos reativos são usados no Slick para inserir dados
NoDocumentação de Slick [http://slick.typesafe.com/doc/3.1.1/dbio.html#streaming]exemplos de uso de fluxos reativos são apresentados apenas para a leitura de dados como um meio de um DatabasePublisher. Mas o que acontece quando você deseja usar ...
Como ler corretamente o Flux <DataBuffer> e convertê-lo em uma única entradaStream
estou a usarWebClient e personalizadoBodyExtractorclasse para meu aplicativo de inicialização por mola WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(MediaType.APPLICATION.XML) .exchange() .flatMap(response ...
Mono vs Flux no Fluxo Reativo
Conforme a documentação: Flux é um fluxo que pode emitir elementos 0..N: Flux<String> fl = Flux.just("a", "b", "c");Mono é um fluxo de 0..1 elementos: Mono<String> mn = Mono.just("hello");E, como ambas são as implementações da interface do ...