Resultados da pesquisa a pedido "reactive-programming"
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 ...
Qual a melhor forma de obter uma matriz de bytes de um ClientResponse do Spring WebClient?
Estou experimentando o novoWebClient do Spring 5 (5.0.0.RC2) em uma base de código que usa programação reativa e tive sucesso ao mapear a resposta JSON de um endpoint para um DTO no meu aplicativo, o que funciona muito bem: WebClient client = ...
Fluxos de Apache Kafka Materializar o KTables para um tópico parece lento
Estou usando o fluxo kafka e estou tentando materializar uma KTable em um tópico. Funciona, mas parece ser feito a cada 30 segundos ou mais. Como / quando o Kafka Stream decide materializar o estado atual de uma KTable em um tópico? Existe ...
RxJS takeWhile, mas inclui o último valor
Eu tenho um pipeline RxJS5 parecido com este Rx.Observable.from([2, 3, 4, 5, 6]) .takeWhile((v) => { v !== 4 })Quero manter a assinatura até ver 4, mas quero que o último elemento 4 também seja incluído no resultado. Portanto, o exemplo acima ...
Inscrever-se com Vs se inscrever no RxJava2 (Android)?
Quando chamar o método subscribeWith em vez de simples assinatura? E qual é o caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
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 ...
Como personalizar a desserialização JSON do SpringWebFlux WebClient JSON?
Estou usando umWebClient do spring-webflux [https://docs.spring.io/spring/docs/5.0.0.BUILD-SNAPSHOT/javadoc-api/org/springframework/web/reactive/function/client/WebClient.html] (build 20170502.221452-172) para acessar um aplicativo Web que produz ...
Um elemento React válido (ou nulo) deve ser retornado. Você pode ter retornado indefinido, uma matriz ou outro objeto inválido
Sou novo no ReactJS e tenho um problema. Eu não consigo resolver isso. Parece que está tudo bem, mas ainda assim o console me coloca: Um elemento React válido (ou nulo) deve ser retornado. Você pode ter retornado indefinido, uma matriz ou outro ...
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 ...