Resultados da pesquisa a pedido "reactive-programming"
Confuso sobre diagramas de switches Yampa
Existem alguns diagramas de switches Yampa ...
Como o ReactiveMongo é implementado para que seja considerado sem bloqueio?
A leitura da documentação sobre o Play Framework e o ReactiveMongo me leva a acreditar que o ReactiveMongo funciona de tal maneira que usa poucos threads e nunca bloqueia. No entanto, parece que a comunicação do aplicativo Play com o servidor ...
Meteor `Deps.autorun` vs` Collection.observe`
Quais são os prós / contras entre usarDeps.autorun ouCollection.observe para manter um widget de terceiros sincronizado com umMeteor.Collection. Por exemplo, estou usando o jsTree para mostrar visualmente uma árvore de diretórios que eu ...
Teste em banana reativa
Existe uma maneira de testar redes unitárias criadas em banana reativa? Digamos que eu construí alguma rede com alguns eventos de entrada - é possível verificar se os eventos produziram algum fluxo / comportamento de saída com algum valor após ...
RestAPIs assíncronos com RxJava / Jersey2. Enfiando perguntas?
Estamos no processo de prototipar uma API REST usando programação reativa. Conforme mostrado no diagrama, mantemos três camadas iguais às usadas em nossos projetos de API de sincronização anteriores; http://oi59.tinypic.com/339hhki.jpg ...
Como restringir a concorrência da maneira correta no Rx.NET
Observe o seguinte trecho de código: var result = await GetSource(1000).SelectMany(s => getResultAsync(s).ToObservable()).ToList();O problema com este código é quegetResultAsync é executado simultaneamente de maneira irrestrita. O que poderia ...
O Slick 3.0 é reativo / assíncrono no nível do driver do banco de dados? Para quais bancos de dados?
Slick historicamente contava com drivers JDBC, que bloqueiam internamente a espera de E / S de soquete em resposta a consultas. Toda chamada de banco de dados pendente requer um encadeamento para bloquear em um soquete; portanto, não é realmente ...
Como fazer chamadas observáveis recursivas no RxJava?
Eu sou muito novo emRxJava [https://github.com/ReactiveX/RxJava](e paradigma reativo em geral), por isso, tenha paciência comigo. Suponha que eu tenho issoNews e isso aninhadoComment estrutura de dados: public class News { public int id; public ...
RxJS: Dividindo um resultado de matriz de Observable.fromPromise
Estou usando o RxJS aqui e não consigo superar issoaparentemente questão simples. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) { console.log('Next'); console.log(x); }, function error (x) ...
RxJava- Cache () é o mesmo que replay ()?
Fiquei me perguntando se havia umcache() operador que poderia armazenar em cache x número de emissões, mas também expirá-las após um intervalo de tempo especificado (por exemplo, 1 minuto). Eu estava procurando por algo como ...