Resultados da pesquisa a pedido "rx-java"
InterruptedIOException ao usar Retrofit2 com rx quando retryOn
Estou usando o retrofit 2 com rx-android Eu tenho uma lógica de repetição bastante complexa,que funciona parcialmente. Cortei o código irrelevante para simplificá-lo. Aqui está: public class RetryWithDelay implements Func1<Observable<? extends ...
RxJava - Encadeando solicitações e atualizando a interface do usuário
O problema que estou tendo é esse. Eu preciso executar algumas solicitações para o servidor. Cada próxima solicitação depende do resultado da anterior. Eles ficam assim (abreviados): Observable<FileUploadResponse> obsFile = ...
Android RxJava, sem bloqueio?
Entendi que o rxjava-android executa operações em um thread separado (quando fornecido o Agendador correto), levando a operações sem bloqueio, no entanto, um teste rápido e sujo parece provar que isso está incorreto. Usei os seguintes trechos de ...
Retrofit / Rxjava e serviços baseados em sessão
Estou implementando serviços baseados em sessão. Todas as solicitações precisam ser assinadas com um parâmetro de sessão de cookie, que por sua vez é recuperado com API de descanso separada. Portanto, o fluxo de trabalho básico seria obter ...
Por que meu temporizador Observable nunca é chamado?
No Android, escrevi umObservable que deve ser chamado uma vez após 2000 ms, mas que nunca é chamado. Observable.timer(2000, TimeUnit.MILLISECONDS) // wait 2000 ...
Como esperar várias chamadas assíncronas aninhadas usando o RxJava-Android?
Eu sou novo no RxJava, aqui está o meu caso, envie a solicitação A e receberáList<A> de voltapara cada A, envie a solicitação AA e receberá AA de volta, vincule A e AA ehá B & BB com lógica semelhantefaça algo somente depois que todos os pedidos ...
Coletar Observáveis em uma Lista não parece emitir a coleção de uma só vez
Estou usando o RxJava para coletar essencialmente a lista de observáveis emitidos individualmente e combiná-los em uma lista de observáveis (essencialmente o oposto do flatMap). Aqui está o meu código: // myEvent.findMemberships() returns an ...
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 ...
RxJava: diferença entre doOnNext e doOnEach
Em quais casos eu devo usar doOnNext e em quais casos doOnEach? .doOnEach(new Action1<Notification<? super MessageProfile>>() { @Override public void call(Notification<? super MessageProfile> notification) { } }) .doOnNext(new ...