Resultados da pesquisa a pedido "rx-java2"

4 a resposta

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

2 a resposta

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

1 a resposta

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

2 a resposta

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

1 a resposta

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>() // ... ...

2 a resposta

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