Resultados da pesquisa a pedido "rx-java"
Aplicar tentativas em um RXjava
Eu quero executar um método com tentativas usando RXJava return Observable .just(myObj) .flatMap(doc -> myFunc(myObj, ....) ) .doOnError(e -> log.Error()) .onErrorResumeNext(myObj2 -> methodIWantToRunWithRetries(...) .onErrorResumeNext(myObj3 ...
Como executar duas consultas seqüencialmente em um Android RxJava Observable?
Quero executar 2 tarefas assíncronas, uma seguida pela outra (sequencialmente). Li algo sobre ZIP ou Flat, mas não entendi muito bem ... Meu objetivo é carregar os dados de um SQLite local e, quando termina, chama a consulta para o servidor ...
Como simular serviços com o Retrofit 2.0 e a nova classe MockRetrofit?
Usando o Retrofit 1, costumávamos zombar de serviços da web e simular a latência da rede da seguinte maneira: MockRestAdapter mockRestAdapter = MockRestAdapter.from(restAdapter); return mockRestAdapter.create(MyService.class, new ...
Região, operações de rede, assinando e observando em diferentes threads com o RxJava
Eu preciso : Buscar alguns dados de uma API em um encadeamento em segundo planoExibir os dados na interface do usuárioSalvar no reino. fetchItemsFromServer().subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()).subscribe(new ...
RxJava; Como emitir observáveis de forma síncrona
Quero emitir de forma síncrona dois objetos Observáveis (que são assíncronos), um após o outro onde retorna oprimeiro objeto observável emitido. Se o primeiro falhar, ele não deve emitir o segundo. Digamos que temos um Observable que faz login ...
Como analisar uma resposta JSON ao usar o retrofit quando a resposta às vezes é um objeto e algumas vezes uma matriz?
Estou usando o Retrofit para obter uma resposta JSON. Aqui estão partes da minha implementação - @GET("/api/report/list") Observable<Bills> listBill(@Query("employee_id") String employeeID);e a classe Bills é - public static class Bills { ...
Diferença entre CompletableFuture, Future e RxJava's Observable
Eu gostaria de saber a diferença entreCompletableFuture,Future eObservable RxJava. O que eu sei é que todos são assíncronos, mas Future.get() bloqueia o fio CompletableFuture fornece os métodos de retorno de chamada RxJava Observable --- ...
Combine RxTextView Observable e Retrofit Observable
Como exemplo para começar a usar o RxAndroid, estou tentando implementar uma caixa de pesquisa que aciona uma chamada de descanso quando os usuários inserem algo. Até agora eu tenho duas partes de trabalho. A primeira observação do EditTextView ...
Como parar e continuar Observable.interval emitindo ticks
Isso emitirá um tique a cada 5 segundos. Observable.interval(5, TimeUnit.SECONDS, Schedulers.io()) .subscribe(tick -> Log.d(TAG, "tick = "+tick));Para pará-lo, você pode usar Schedulers.shutdown();Mas todos os agendadores param e não é possível ...
Observável é executado no encadeamento principal, embora subscribeOn () seja chamado em outro encadeamento
Eu tive um problema estranho em uma das minhas atividades. Ao voltar de tirar uma foto / vídeo, no meuonActivityResult Estou mostrando uma caixa de diálogo que permite ao usuário nomear a câmera. Depois que o usuário pressionar OK, ...