Resultados da pesquisa a pedido "reactive-programming"
Como criar um buffer RxJS que agrupa elementos no NodeJS, mas que não depende de um intervalo de execução permanente?
Estou capturando eventos de um aplicativo usandoRx.Observable.fromEvent em um NodeJS. Eles são enviados para outro servidor usando request ( https://www.npmjs.com/package/request [https://www.npmjs.com/package/request]) Para evitar uma carga de ...
Brilhante: qual é a diferença entre observeEvent e eventReactive?
Li a documentação do Shiny sobre programação reativa algumas vezes agora, mas não consigo entender corretamente a diferença entreobserveEvent eeventReactive. A documentação diz: Use observeEvent sempre que desejar executar uma ação em resposta ...
Transmissão em slick / scala
Estou olhando para o scala / slick streaming e tentando entender como funciona. Aqui está o meu código de teste val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize = 100)).foreach ...
Pesquisa de banco de dados com extensões reativas
Eu tenho que consultar um banco de dados em tempo hábil para conhecer o estado de um sistema legado. Eu pensei em agrupar a consulta em torno de umObservable, mas não sei a maneira correta de fazer isso. Basicamente, será a mesma consulta a cada ...
Como solicitar dados sequencialmente no Cycle.js?
Eu sou novo na programação reativa e brinco com o cycle.js, tentando implementar a caixa a seguireste tutorial [https://gist.github.com/staltz/868e7e9bc2a7b8c1f754]. Mas entendi que, para a implementação adequada (e para fins de aprendizado), não ...
O rxjs observable não é concluído quando ocorre um erro
Quando crio um observável a partir do zero e o erro do observador é concluído, a parte concluída da assinatura nunca é chamada. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); observer.onCompleted(); ...
O RxJava é adequado para ramificar fluxos de trabalho?
Estou usando o RxJava para processar algumas notificações que extraímos de uma fila. O RxJava parecia funcionar bem com um fluxo de trabalho simples, agora com novos requisitos chegando, o fluxo está crescendo em complexidade com ...
RxJs: Como fazer um loop com base no estado do observável?
Estou tentando fazer com que os RxJs façam um loop sobre um Observable no meu fluxo até que ele esteja em um determinado estado e depois o fluxo continue. Especificamente, estou convertendo um loop síncrono do / while em RxJs, mas presumo que a ...
Falta inexplicável de melhoria de desempenho usando Observáveis RxJava em aplicativos da Web
Estou realizando alguns testes para avaliar se há uma vantagem real no uso de APIs reativas baseadas em Observables, em vez das tradicionais de bloqueio. O exemplo inteiro édisponível no ...
Criando abas dinamicamente com plotagens brilhantes, sem recriar as abas existentes
Gostaria de criar guias dinâmicas, onde cada vez que o usuário clica em um botão, uma nova guia é criada. Cada guia tem o mesmo conteúdo, com uma variedade de widgets que o usuário pode usar para selecionar quais conjuntos de dados serão ...