Resultados da pesquisa a pedido "rx-java2"
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?
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 ...
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() { ...
Inscrever-se com Vs se inscrever no RxJava2 (Android)?
Quando chamar o método subscribeWith em vez de simples assinatura? E qual é o caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
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". ...
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 ...
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 ...
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?