Resultados da pesquisa a pedido "reactive-programming"
Pode manipular ciclos de banana reativa na rede?
Temos código como este: guiState :: Discrete GuiState guiState = stepperD (GuiState []) $ union (mkGuiState <$> changes model) evtAutoLayout evtAutoLayout :: Event GuiState evtAutoLayout = fmap fromJust . filterE isJust . fmap autoLayout $ ...
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 ...
Chamar setState na renderização não é evitável
O documento React indica que orender função deve serpuroo que significa que não deve usarthis.setState No entanto, acredito que quando o estado depende de 'remoto', isto é, resultado de uma chamada ajax. A única solução ésetState() dentro de ...
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 ...
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], ...
C # .NET Rx - Onde está System.Reactive?
Eu tenho uma experiência intensiva em Java, então me perdoe se estiver ignorando algo óbvio em C #, mas minha pesquisa não está me levando a lugar algum. Estou tentando usar a biblioteca Rx .NET reativa. O compilador não está ...
Encadeando sinais dependentes em ReactiveCocoa
Em ReactiveCocoa, se encadearmos vários sinais dependentes, devemos usar
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 ...
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 ...
Mono vs Flux no Fluxo Reativo
Conforme a documentação: Flux é um fluxo que pode emitir elementos 0..N: Flux<String> fl = Flux.just("a", "b", "c");Mono é um fluxo de 0..1 elementos: Mono<String> mn = Mono.just("hello");E, como ambas são as implementações da interface do ...