Resultados da pesquisa a pedido "reactive-programming"

2 a resposta

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

4 a resposta

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

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

2 a resposta

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

2 a resposta

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

2 a resposta

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

2 a resposta

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

2 a resposta

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

1 a resposta

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

2 a resposta

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