Resultados da pesquisa a pedido "rx-java2"
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 ...
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>() // ... ...
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 ...
solicitação múltipla da API usando retrofit e rx java
Eu sou novo no android e tenho um cenário em que quero obter dados de várias APIs. Vamos suporapi_a, api_b, api_c, api_d. Essas APIs são independentes uma da outra, mas eu quero mostrar dados dessas APIs em uma mistura Recycler View ( horizontal ...
O resultado da assinatura não é usado
Atualizei para o Android Studio 3.1 hoje, o que parece ter adicionado mais algumas verificações. Uma dessas verificações de fiapos é para RxJava2 de uma só vezsubscribe() chamadas que não são armazenadas em uma variável. Por exemplo, obtendo uma ...
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 ...
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". ...
Repetir uma chamada com o Retrofit 2 e o RxJava2 após exibir uma caixa de diálogo
Estou chamando uma API usando Retrofit 2 e RxJava2. Se uma chamada falhar, em alguns casos (por exemplo, sem conexão à Internet), desejo exibir uma caixa de diálogo de erro ao usuário e permitir que ele tente novamente. Como eu estou usando ...
Quando usar o RxJava no Android e quando usar o LiveData dos componentes arquitetônicos do Android?
Não estou entendendo o motivo de usar o RxJava no Android e o LiveData a partir dos componentes arquitetônicos do Android. Seria realmente útil se os casos de uso e as diferenças entre os dois forem explicados, juntamente com um exemplo ...
Qual é a diferença entre chaves e chaves normais no RxJava com Kotlin
Eu não entendo a diferença real entre as chaves e as chaves normais no Kotlin ao usar o RxJava. Por exemplo, eu tenho o seguinte código que funciona conforme ...