Resultados da pesquisa a pedido "rx-java"
EventBus / PubSub vs (extensões reativas) RX com relação à clareza do código em um único aplicativo encadeado
Atualmente, estou usando um EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]arquitetura / padrão com Scala (e JavaFX) para implementar um aplicativo de organização de notas simples (como um cliente do Evernote com ...
Produto cartesiano em RxJava
É possível obter o produto cartesiano de dois observáveis em rxjava? Algo assim: A -> 1,2,3 B -> a,b A x B -> (1, a), (1, b), (2, a), (2, b), (3, a), (3, b)
Buffer RxJava até ser alterado
Eu tenho um observável que emite um grande número de dados como [1,1,1,2,2,2,3,3,1,1,5,5 ......] No RxJava, podemos usardistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]para obter itens distintos até que ele ...
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 ...
Observer.onError disparando inconsistentemente
Estou usando o Retrofit para acessar minha API da seguinte maneira: public interface UserService { ... @POST("/user/login") public Observable<User> register(@Body() User user); }Aqui está como eu acesso minha API: mUserService.register(user) ...
Como criar um Observable a partir do OnClick Event Android?
Eu sou novo em programação reativa. Portanto, tenho um problema ao criar um fluxo a partir de um evento, como onClick, ontouch ... Alguém pode me ajudar a resolver este problema. Obrigado.
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 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 ...