Resultados da pesquisa a pedido "project-reactor"
Por que o Spring ReactiveMongoRepository não tem um método para salvar o Mono?
Eu tenho um MovieRepository que estendeu o ReactiveMongoRepository. Quero salvar um único POJO de maneira reativa. Mas ReactiveMongoRepository não fornece o método de salvar para Mono ou Publisher. Eu tenho que usarblock() método ou use osaveAll ...
Como executar a sequência de operações e garantir que uma operação seja concluída antes da próxima no aplicativo da web do Spring Reactor?
Tenho o aplicativo Web Spring Boot 2 no qual preciso identificar o visitante do site por cookie e coletar estatísticas de exibição da página. Então, preciso interceptar todas as solicitações da web. O código que eu tive que escrever é mais ...
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 ...
Spring 5 Web Reactive - Como podemos usar o WebClient para recuperar dados transmitidos em um fluxo?
A documentação atual, marco (M4) mostra e exemplo sobre como recuperar umMono usandoWebClient: WebClient webClient = WebClient.create(new ReactorClientHttpConnector()); ClientRequest<Void> request ...
O método publishOn of Flux não funciona conforme o esperado
Estou tentando integrar um consumidor de bloqueio como umFluxoassinante no Reator Alumínio-SR1. Eu gostaria de usar um paraleloAgendador, para executar as operações de bloqueio simultaneamente. Eu implementei uma classe principal para descrever ...
Como você realmente “gerencia” o número máximo de webthreads usando a Programação Reativa do Spring 5?
Ao usar uma abordagem clássica do Tomcat, você pode fornecer ao servidor um número máximo de threads que ele pode usar para lidar com solicitações da Web dos usuários. Usando o paradigma de Programação Reativa e o Reator na Primavera 5, podemos ...
Como criar um fluxo de reator de mola a partir do fluxo de integração Http?
Eu tenho uma pergunta muito semelhante a estaComo criar um fluxo do Spring Reactor a partir de uma fila do ActiveMQ? [https://stackoverflow.com/questions/43126775/how-to-create-a-spring-reactor-flux-from-a-activemq-queue] Com uma diferença, as ...
Como registrar corpos de solicitação e resposta no Spring WebFlux
Desejo ter o registro centralizado de solicitações e respostas na minha API REST no Spring WebFlux com Kotlin. Até agora eu tentei essas abordagens @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { ...
Como coletar respostas de API paginadas usando o WebClient de inicialização por primavera?
Tenho uma resposta paginada de um URL, quero continuar acessando o URL da próxima página que recebo da resposta anterior e continuar coletando itens até não ter um URL "nextPage" na minha resposta. Como conseguir isso de maneira reativa usando o ...
Como converter <Lista <>> Mono em Fluxo <>
Estou convertendo um projeto pequeno escrito no RxJava 1.x para o Reactor 3.x. Tudo está bem, exceto que eu não consegui descobrir como substituirflatMap(Observable::from) com a contrapartida apropriada. eu tenhoMono<List<String>> e eu preciso ...
Página 1 do 2