Resultados da pesquisa a pedido "rx-java2"
ConcatMapSingle flutuável sem pré-busca para ignorar cliques até o processamento terminar
Eu quero lidar com cliques de forma que eles sejam ignorados desde que eu esteja processando algum clique que ocorre Eu pensei que poderia fazê-lo utilizando a contrapressão, assim: private val clicks = PublishProcessor.create<Unit>() // ... ...
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: ...
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 ...
Por que a operação de exclusão de sala (com RxJava) fornece erro de thread da interface do usuário, mesmo especificando diferentes threads de inscrição?
Então, simplesmente, o DAO @Query("DELETE FROM Things WHERE someIdOfTheThing IN (:listOfId)") abstract fun deleteThings(listOfId: MutableList<String>): Maybe<Int>uso mDisposables.add(mThingsDao ...
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() { ...
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 ...
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?
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 ...
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 ...
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 = ...