Resultados da pesquisa a pedido "rx-java2"

2 a resposta

Usando RxJava 2 e Retrofit 2, problema de versão do adaptador

Adicionei um novo módulo de biblioteca ao módulo de aplicativo existente no Android Studio. A principal diferença foi adicionar o RxJava 2 e o Retrofit 2. Após atualizar o build.gradle do novo módulo, comecei a receber o próximo erro: Erro: ...

3 a resposta

Manipular resposta vazia com retrofit e rxjava 2.x

Ao usar o rxjava 1.x, eu costumava retornarObservable<Void> para lidar com a resposta vazia do retrofit: @POST( "login" ) Observable<Void> getToken( @Header( "Authorization" ) String authorization, @Header( "username" ) String username, @Header( ...

1 a resposta

Como assinar vários assinantes do Observable ou Flowable?

No exemplo Hello World, há um assinante public static void main(String[] args) { Flowable.just("Hello world").subscribe(System.out::println); }Como fazer dois ou mais?

1 a resposta

Assunto RxJava com contrapressão - deixe apenas o último valor emitir quando o downstream terminar de consumir

Eu tenho um PublishSubject que chamaonNext() em algum evento da interface do usuário. O assinante normalmente leva 2 segundos para concluir seu trabalho. Preciso ignorar todas as chamadas paraonNext() exceto o último enquanto o assinante estiver ...

3 a resposta

RxAndroid e Retrofit: Não foi possível criar o adaptador de chamada para io.reactivex.Observable <retrofit2.Response <okhttp3.ResponseBody >>

Estou tentando usar rxJava, rxAndroid, Retrofit2 e OkHTTP3 para baixar um arquivo de um ponto de extremidade de URL. Meu código não pode criar o adaptador de chamada para um "Observable <retrofit2.Response <okhttp3.ResponseBody >>". Esses métodos ...

3 a resposta

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

2 a resposta

Inferência de tipo mais recente no kotlin

Estou usando RxJava2, Kotlin-1.1 junto com RxBindings no meu projeto. Tenho uma tela de login simples com o botão 'login' desativado por padrão. Quero ativar o botão apenas quando os campos edittext de nome de usuário e senha não estiverem ...

2 a resposta

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?

2 a resposta

Qual é a diferença entre RxJava 2 Cancellable e Disposable?

Eu quero criar umObservable da vista, clique em listener usando o RxJava 2. Comecei da implementação mais simples (não uso lambdas aqui para mostrar diferentes tipos nesse método): Observable<View> viewObservable = ...

8 a resposta

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