Resultados da pesquisa a pedido "rx-java"
Operador RxJava que emite se diferente do último
Existe um operador que emita itens se o item a ser emitido não for igual ao último item emitido?
Executar o método nulo em segundo plano
Eu quero executar um método em segundo plano usando rxjava. Eu não ligo para o resultado. void myHeavyMethod() { (...) }Até agora, a única solução que tenho é modificar o tipo de retorno para, por exemplo.boolean. boolean myHeavyMethod() { ...
RxBindings para Spinner?
Eu sou novo android e rxjava. Já passei por muitos exemplos em que ouvimos eventos com rxbindings. tal como este RxView.clicks(b).subscribe(new Action1<Void>() { @Override public void call(Void aVoid) { // do some work here } ...
Teste JUnit do Android RxJava 2 - getMainLooper no android.os.Looper não zombou RuntimeException
Estou encontrando uma RuntimeException ao tentar executar testes JUnit para um apresentador que está usandoobserveOn(AndroidSchedulers.mainThread()). Como são testes puros JUnit e não testes de instrumentação Android, eles não têm acesso às ...
RxJava 2 substituindo o agendador de E / S no teste de unidade
Estou tentando testar o seguinte código RxKotlin / RxJava 2: validate(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { ... }Estou tentando substituir os agendadores da seguinte maneira: // Runs before ...
Rx Java Android: Como converter esse bloco de retorno de chamada em Observer
Estou tentando fazer upload de um arquivo via SDK para Android S3 da Amazon. Eu usei o RX Java um pouco, mas não sei como converter esse método para um método que retorna um Observable, porque quero encadear o resultado desse método para outra ...
Padrão RxJava para solicitar um Observable remoto com um cache temporário
O caso de uso é o seguinte: desejo armazenar em cache temporariamente a última resposta observável cara emitida, mas depois que ela expirar, retorne à fonte cara Observable e faça o cache novamente, etc. Um cenário de cache de rede bastante ...
Como processar os primeiros n itens e permanecer um de maneira diferente em um fluxo observável
por exemplo, dado um fluxo de um certo número (m) de números (m1, m2, m3, m4, m5, m6 ...) e aplique uma transformação (2 * i) nos primeiros n itens (n pode ser menor, igual ou maior que m), aplique outra transformação (3 * i) aos itens ...
Qual é a diferença entre Observable, Completable e Single no RxJava
Alguém pode explicar a diferença entre Observável, Completável e Único no RxJava com exemplos claros? Em que cenário usamos um sobre os outros?
Como encadear dois Completable em RxJava2
Eu tenho dois Completable. Gostaria de fazer o seguinte cenário: Se o primeiro Completável chegar ao onComplete, continue com o segundo Completável. Os resultados finais seriam concluídos no segundo Completável. É assim que eu faço quando tenho ...