Resultados da pesquisa a pedido "reactive-programming"
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á ...
tap () não é acionado no Pipe RXJS
Tenho que fazer o mesmo, embora prefira o primeiro. Mas a primeira abordagem não parece funcionar. (atap() não é acionado) // does not work this.actions$.pipe( ofType(LayoutActions.Types.CHANGE_THEME), takeUntil(this.destroyed$), tap(() => { ...
Cadeia de dois observáveis retrofit com RxJava
Eu quero executar 2 chamadas de rede uma após a outra. As duas chamadas de rede retornam Observable. A segunda chamada usa dados do resultado bem-sucedido da primeira chamada, o método no resultado bem-sucedido da segunda chamada usa dados ...
Como cancelar tarefas com retrofit e rxjava
Eu tenho API de descanso. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Eu sei que o okhttp tem funcionalidade de cancelamento (por objeto de solicitação, por tag), mas não sei como usá-lo com retrofit e ...
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 ...
Mecanismo de contrapressão no Spring Web-Flux
Eu sou iniciante emSpring Web-Flux. Eu escrevi um controlador da seguinte maneira: @RestController public class FirstController { @GetMapping("/first") public Mono<String> getAllTweets() { return Mono.just("I am First Mono") } }Eu sei que um dos ...
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 ...
Alterne entre layouts reativamente com brilho
Como alternar entre layouts de página no Shiny em resposta à entrada do usuário? Por exemplo, eu gostaria de alternar entre um layout da barra lateral e um layout do painel de poço para que os gráficos possam abranger a página inteira. O que ...
RxJS: Como eu "manualmente" atualizava um Observable?
Acho que devo estar entendendo mal algo fundamental, porque, na minha opinião, esse deve ser o caso mais básico para um observável, mas, durante toda a vida, não consigo descobrir como fazê-lo a partir dos documentos. Basicamente, eu quero ser ...