Resultados da pesquisa a pedido "reactive-programming"

5 a resposta

Como obter String de Mono <> em java reativo

Eu tenho um método que aceita Mono como um parâmetro. Tudo o que eu quero é obter a String real. Pesquisou no Google, mas não encontrou resposta, exceto chamar o bloco () sobre o objeto Mono, mas ele fará uma chamada de bloqueioentão quer evitar ...

1 a resposta

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()) ...

6 a resposta

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 ...

1 a resposta

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 ...

1 a resposta

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 = ...

5 a resposta

RxJava Combine Sequence Of Requests

O problemaEu tenho duas Apis. A API 1 fornece uma lista de itens e a API 2 fornece informações mais detalhadas para cada um dos itens que obtive da API 1. A maneira como eu a resolvi até agora resulta em um desempenho ruim. A questãoSolução ...

3 a resposta

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 ...

1 a resposta

Entrada reativa de renderDataTable

ATUALIZAÇÃO (18 de dezembro de 2015)A melhor abordagem atual para esse problema está aqui:Obter linha selecionada do DataTable no aplicativo ...

3 a resposta

RxJava: como compor vários observáveis com dependências e coletar todos os resultados no final?

Estou aprendendo RxJava e, como minha primeira experiência, tentando reescrever o código na primeirarun() método emesse código [https://gist.github.com/benjchristensen/4671081](citado emBlog da ...

4 a resposta

EventBus / PubSub vs (extensões reativas) RX com relação à clareza do código em um único aplicativo encadeado

Atualmente, estou usando um EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]arquitetura / padrão com Scala (e JavaFX) para implementar um aplicativo de organização de notas simples (como um cliente do Evernote com ...