Resultados da pesquisa a pedido "rx-java"

3 a resposta

Como transformar uma lista aninhada de valores duplos em uma classe Java usando RxJava?

No meu cliente Android, recebo esses dados JSON de um back-end: [ [ 1427378400000, 553 ], [ 1427382000000, 553 ] ]Aqui está a rotina que realmente carrega os dados. estou ...

2 a resposta

Como implementar o observeLatestOn no RxJava (RxScala)?

Estou tentando implementar oObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] operador em RxJava (na ...

6 a resposta

Entregue o primeiro item imediatamente, 'devolva' os seguintes itens

Considere o seguinte caso de uso: precisa entregar o primeiro item o mais rápido possívelprecisorebater seguintes eventos com tempo limite de 1 segundoAcabei implementando um operador personalizado com base emOperatorDebounceWithTime então ...

3 a resposta

Use RxJava e Retrofit para percorrer os resultados da lista e aumentar com base em subconsultas

Estou usando o retrofit e acho que o rxjava (com retrolambda) seria um bom ajuste para o seguinte fluxo: obter lista de widgets (http)para cada widget a) obtenha uma lista de artigos (http) para o tipo de widget especificado b) salve todos para ...

2 a resposta

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

2 a resposta

Como lidar com o erro auth0 403 sem adicionar código específico em qualquer lugar (Retrofit / okhttp / RxAndroid)

Estou usando o Auth0, que me fornece um JWT (json web token) e um refreshtoken. Eu uso esse JWT nos cabeçalhos http para me comunicar com meu back-end. Pode acontecer que o servidor me dê uma403, quando decide que o JWT expirou. Nesse caso, ...

1 a resposta

RxJava: “java.lang.IllegalStateException: apenas um assinante permitido!”

Estou usando o RxJava para calcular a correlação automática normalizada em alguns dados do sensor no Android. Estranhamente, meu código gera uma exceção ("java.lang.IllegalStateException: apenas um assinante é permitido!") E não tenho certeza do ...

2 a resposta

Como cancelar tarefas com retrofit e rxjava

Eu tenho API de descanso. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Eu sei que o okhttp tem funcionalidade de cancelamento (por objeto de solicitação, por tag), mas não sei como usá-lo com retrofit e ...

4 a resposta

RxJava - Just vs From

Estou recebendo a mesma saída ao usarObservable.just vsObservable.from no seguinte caso: public void myfunc() { //swap out just for from here and i get the same results,why ? Observable.just(1,2,3).subscribe(new Subscriber<Integer>() { @Override ...

1 a resposta

Nova tentativa do RxJava com base na lógica

Aqui está o caso, eu tenho uma API chamada de Retrofit que pode falhar devido a um erro de rede. Se falhar, mostraremos a mensagem de erro com um botão de repetição. Quando o usuário pressiona o botão Repetir, precisamos repetir o último ...