Resultados da pesquisa a pedido "reactive-programming"
Implementando um operador tipo torniquete com o RxJava
Preciso de ajuda para implementar um operador semelhante ao torniquete no RxJava (RxScala). Passei bastante tempo pensando sobre isso, mas pareço estar presa. O tipo da função deve ser o seguinte: def turnstile[T](queue: Observable[T], ...
O scala oferece E / S assíncronas sem bloqueio ao trabalhar com arquivos?
Estou usando o scala 2.10 e gostaria de saber se existe algum pacote que tenha E / S assíncrona ao trabalhar com arquivos? Eu fiz alguma pesquisa neste tópico, mas encontrei principalmente exemplos como a seguir val file = new ...
MeteorJS - Preste atenção na alteração da variável do servidor e atualize o valor do modelo
Tenho uma dúvida. Não tenho certeza se é possível e não encontrou uma resposta clara sobre isso. É possível adicionar um "observador" a uma variável do servidor para que, quando o valor for alterado, eu possa atualizar a exibição (lado do ...
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 ...
RxJava Observando na chamada / assinatura do thread
Estou com alguns problemas para entender como o subscribeOn / observeOn funciona no RxJava. Eu criei um aplicativo simples com observável que emite nomes de planetas do sistema solar, faz alguns mapeamentos e filtros e imprime resultados. Pelo ...
Lutando com FRP
Eu li sobre FRP e fiquei muito animado. Parece ótimo, para que você possa escrever mais código de alto nível, e tudo seja mais compostável, etc. Depois, tentei reescrever meu próprio joguinho com algumas centenas de sloc de js simples para ...
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 ...
Gerenciar solicitações idênticas com o RxJava
Suponha que eu tenho um buscador que busca uma imagem de um determinado link em um thread separado. A imagem será armazenada em cache na memória. Quando a imagem já estiver em cache, o buscador não buscará novamente o link. O buscador é ...
Como implementar o observeLatestOn no RxJava (RxScala)?
Estou tentando implementar oObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] operador em RxJava (na ...