Resultados da pesquisa a pedido "rx-java"
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 lidar com paginação com RxJava?
Estou pensando em converter meu aplicativo Android para usar Rxjava para solicitações de rede. Atualmente, acesso um serviço da web semelhante a: getUsersByKeyword(String query, int limit, int offset)Pelo que entendi, os Observáveis são uma ...
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 ...
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], ...
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 + retrofit, obtenha uma lista e adicione informações extras para cada item
Estou brincando com o RXJava, adaptado no Android. Estou tentando fazer o seguinte: Preciso pesquisar periodicamente uma chamada que me dê um Observable> (A partir daqui eu poderia fazer isso) Depois de obter essa lista, quero iterar em cada ...
Android: sondando um servidor com Retrofit
Estou criando um jogo para 2 jogadores no Android. Como o jogo funciona no sentido horário, o jogador 1 espera até que o jogador 2 faça sua entrada e vice-versa. Eu tenho um servidor da web em que executo uma API com ...
Como compor Observables para evitar os retornos de chamada aninhados e dependentes?
Noeste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , ele dáesta [https://gist.github.com/benjchristensen/4677544](copie / cole o código a seguir) ...
Qual é o objetivo do doOnNext (…) no RxJava
Quando devemos usardoOnNext () [http://reactivex.io/RxJava/javadoc/rx/Observable.html#doOnNext(rx.functions.Action1)] de Observable em vez de apenas onNext ()?