Resultados da pesquisa a pedido "reactive-programming"
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 ...
Como combinar três observáveis do firebase sem perder atualizações dinâmicas
Eu tenho um 3 firebase paralelo requer. E eu preciso me juntar a eles como um único objeto. Código como abaixo: import {Http} from "@angular/http"; import {AngularFireDatabase} from "angularfire2"; import {Thread} from "../model/thread"; import ...
Rxjs - Como extrair vários valores dentro de uma matriz e devolvê-los ao fluxo observável de forma síncrona
Eu criei umRx.Observable de um fluxo de eventos: Rx.Observable.fromEvent(recognizeStream, 'data')No qual cada evento de dados se parece com isso: { error: null, alternatives: [result1, result2, result3] }Eu quero extrair todo valor dentro da ...
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 ...
R Erro de reatividade de entrada brilhante ao arrastar e soltar
No momento, estou criando um aplicativo R Shiny com alguns js personalizados para fornecer a funcionalidade de arrastar e soltar. Enquanto o recurso de arrastar e soltar funciona perfeitamente para um único arquivo, quando eu o redefino usando o ...
Importando Operadores RxJS Permitidos
O RxJS 5.5 faz uma grande mudança e introduzoperadores letáveis [https://github.com/ReactiveX/rxjs/blob/master/doc/lettable-operators.md]para substituir basicamente todos os operadores (chamados de "patches") que costumávamos usar antes. Esse ...
WebClient vs RestTemplate
Conforme a primavera 5: O WebClient é uma interface que representa o principal ponto de entrada para executar solicitações da web. Ele foi criado como parte do módulo Spring Web Reactive e substituirá o RestTemplate clássico nesses cenários. O ...
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 ...
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 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 ...