Resultados da pesquisa a pedido "rx-java"
Como um Observable pode ser pausado sem perder os itens emitidos?
eu tenho umObservable que emite tiques a cada segundo: Observable.interval(0, 1, TimeUnit.SECONDS) .take(durationInSeconds + 1)); Gostaria de pausar este Observable para que ele pare de emitir números e retomá-lo sob demanda. Existem algumas ...
RxJava: itens de buffer até que alguma condição seja verdadeira para o item atual
Aqui está um trecho que estou tentando descobrir: class RaceCondition { Subject<Integer, Integer> subject = PublishSubject.create(); public void entryPoint(Integer data) { subject.onNext(data); } public void client() { subject /*some ...
Como lidar com erros de rede no Retrofit 2 com RxJava
Estou usando o Retrofit2 com o RxJava. Então, minha ligação parece algo como subscriptions.add(authenticateUser(mReq, refreshRequest) .observeOn(Schedulers.io()) .subscribeOn(Schedulers.io()) .subscribe(authResponseModel -> { ...
RxJava: como aplicar condicionalmente operadores a um observável sem quebrar a cadeia
Eu tenho uma cadeia de operadores em um observável RxJava. Eu gostaria de poder aplicar um dos dois operadores, dependendo de um valor booleano sem "quebrar a cadeia". Sou relativamente novo em Rx (Java) e sinto que provavelmente há uma ...
Retrofit Android 2 + RxJava: ouça um fluxo interminável
Posso usar o Retrofit + RxJava para ouvir um fluxo interminável? Por exemplo, o fluxo do Twitter. O que eu tenho é isso: public interface MeetupAPI { @GET("http://stream.meetup.com/2/rsvps/") Observable<RSVP> getRSVPs(); } MeetupAPI api = new ...
RxAndroid - tente novamente observável ao clicar
Estou usando o rxAndroid e o rxKotlin no meu aplicativo Android para lidar com solicitações de rede de forma assíncrona. Agora, gostaria de tentar novamente uma solicitação de rede com falha somente depois de clicar no botão Snackbar. Meu código ...
Firebase offline sem CompletionListener em setValue
Eu tenho essa base de código onde defino um valor. No modo offline, ele grava com êxito, mas não está chamando a função de retorno de chamada CompletionListener.onComplete. newOrderRef.setValue(order, (firebaseError, firebase) -> { if ...
Quando o comportamento bizarro
Estou brincando com o RxJavatente novamente [http://reactivex.io/documentation/operators/retry.html]operador. Muito pouco se encontra sobre ele na internet, o único digno de menção ...
Retrofit2 Recursão da cauda usando RxJava / RxAndroid
Estou realmente tentando entender como usarRetrofit comRxJava / RxAndroid. Eu fiz isso usando normalRetrofit2 Callback método em um aplicativo anterior sem o uso deReactive Programming e funcionou bem. Então aqui está. eu precisoTail Recall uma ...
Como obter o URL da solicitação no retrofit 2.0 com o rxjava?
Estou tentando atualizar para o Retrofit 2.0 e adicionar RxJava no meu projeto Android. Estou fazendo uma chamada api e quero recuperar o URL e os dados de resposta no sqlite como cache Observable<MyResponseObject> apiCall(@Body body);E na ...