Resultados da pesquisa a pedido "rx-java"
Solicitações de encadeamento no Retrofit + RxJava
Eu tenho 2 APIs que eu quero fazer solicitação em sequência e armazenar seus dados no SQLite. Primeiro, quero fazer uma solicitação à APIA e armazena seus dados na tabela SQLa. Em seguida, faça uma solicitação à APIB e armazene seus dados na ...
Como lidar com paginação com RxJava?
Estou pensando em converter meu aplicativo Android para usar Rxjava para solicitações de rede. Atualmente, acesso um serviço da web semelhante a: getUsersByKeyword(String query, int limit, int offset)Pelo que entendi, os Observáveis são uma ...
RxJava 2 substituindo o agendador de E / S no teste de unidade
Estou tentando testar o seguinte código RxKotlin / RxJava 2: validate(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { ... }Estou tentando substituir os agendadores da seguinte maneira: // Runs before ...
RxJava + retrofit, obtenha uma lista e adicione informações extras para cada item
Estou brincando com o RXJava, adaptado no Android. Estou tentando fazer o seguinte: Preciso pesquisar periodicamente uma chamada que me dê um Observable> (A partir daqui eu poderia fazer isso) Depois de obter essa lista, quero iterar em cada ...
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 -> { ...
Cadeia de dois observáveis retrofit com RxJava
Eu quero executar 2 chamadas de rede uma após a outra. As duas chamadas de rede retornam Observable. A segunda chamada usa dados do resultado bem-sucedido da primeira chamada, o método no resultado bem-sucedido da segunda chamada usa dados ...
Fazer outra chamada de Retrofit na emissão de Assunto
Eu tenho uma classe a seguir: public class SessionStore { Subject<Session, Session> subject; public SessionStore() { subject = new SerializedSubject<>(BehaviorSubject.create(new Session()); } public void set(Session session) { ...
Por que meu temporizador Observable nunca é chamado?
No Android, escrevi umObservable que deve ser chamado uma vez após 2000 ms, mas que nunca é chamado. Observable.timer(2000, TimeUnit.MILLISECONDS) // wait 2000 ...
Retrofit chamada API recebe "HTTP FAILED: java.io.IOException: Canceled"
Não consigo descobrir por que isso está acontecendo. Nenhum dos retornos de chamada rx (onCompleted (), onError (), onNext ()) não é acionado pela minha chamada. A única coisa que recebo é esta saída okhttp: D/OkHttp: --> ...
Listas de participação no Android RxJava
Tentando entender tudo o que RxJava. Eu estava fazendo o seguinte exemplo: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return ...