Resultados da pesquisa a pedido "rx-java"

1 a resposta

RxJava - Terminando Fluxos Infinitos

3 a resposta

Como é possível cancelar a assinatura de PublishSubject e BehaviorSubject?

Debaixo desubjects pacote você tem aulas comoPublishSubject eBehaviorSubject que suponho que possa ser descrito como uma amostra utilizávelObservables. Como esses assuntos podem ser cancelados? Não háunsubscribe método e chamadaonCompleted ...

12 a resposta

rxjava: Posso usar retry () mas com atraso?

Estou usando o rxjava no meu aplicativo Android para lidar com solicitações de rede de forma assíncrona. Agora, gostaria de tentar novamente uma solicitação de rede com falha somente após um certo tempo. Existe alguma maneira de usar retry () em ...

3 a resposta

RxJava: como compor vários observáveis com dependências e coletar todos os resultados no final?

Estou aprendendo RxJava e, como minha primeira experiência, tentando reescrever o código na primeirarun() método emesse código [https://gist.github.com/benjchristensen/4671081](citado emBlog da ...

4 a resposta

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 ...

3 a resposta

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)

1 a resposta

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 ...

2 a resposta

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) ...

4 a resposta

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.

1 a resposta

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 ...