Resultados da pesquisa a pedido "rx-java"
O RxJava é adequado para ramificar fluxos de trabalho?
Estou usando o RxJava para processar algumas notificações que extraímos de uma fila. O RxJava parecia funcionar bem com um fluxo de trabalho simples, agora com novos requisitos chegando, o fluxo está crescendo em complexidade com ...
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 ...
Obter o instantâneo do GoogleMap em segundo plano
Estou tentando obter o instantâneo de um GoogleMap (do MapView) em segundo plano, retorná-lo com um retorno de chamada e mostrá-lo em um ImageView. Enquanto isso, estou tentando tornar a parte do snapshot independente do layout o máximo possível ...
Qual é a maneira correta de cancelar a inscrição no Single
Quero fazer algo após um pequeno atraso: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Agora eu tenho um aviso:"The result of subscribe is not used". ...
RxJava Combine Sequence Of Requests
O problemaEu tenho duas Apis. A API 1 fornece uma lista de itens e a API 2 fornece informações mais detalhadas para cada um dos itens que obtive da API 1. A maneira como eu a resolvi até agora resulta em um desempenho ruim. A questãoSolução ...
Retomar fluidos convertidos em dados ativos após a rotação da tela
Digamos que eu tenha uma atividade como esta: public class TestActivity extends AppCompatActivity { @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); final TextView countdown = ...
Retrofit + Rxjava leva muito tempo para chamar onError quando a conexão do servidor falha
Estou usando o Retrofit + Rxjava para obter uma lista de entidades do servidor, conforme o projeto, quando a tarefa falha, primeiro verifica a conexão com a Internet e depois verifica a conexão com o servidor emdoOnError ...
Kotlin quádruplo, quintuplo, etc. para desestruturação
Estou procurando uma maneira limpa de criar objetos destrutíveis em linha.kotlin.Pair ekotlin.Triple abrangem muitos casos de uso, mas às vezes há mais objetos que precisam ser passados. Um exemplo de caso de uso é o RXzip , em que os resultados ...
Inscrever-se com Vs se inscrever no RxJava2 (Android)?
Quando chamar o método subscribeWith em vez de simples assinatura? E qual é o caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
Como fornecer contexto com Dagger2
Estou aprendendo o Android e estou seguindo alguns guias para o Retrofit2 com RxJava e Dagger2. Agora eu quero lidar com nenhum caso de conexão à Internet. Eu encontrei issoresponda [https://stackoverflow.com/a/40667193/5058677], que parece ...