Resultados da pesquisa a pedido "rx-java"
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 --- ...
RxJava como barramento de eventos?
Estou começando a aprender RxJava e gosto até agora. Eu tenho um fragmento que se comunica com uma atividade ao clicar no botão (para substituir o fragmento atual por um novo). O Google ...
RxJava- Cache () é o mesmo que replay ()?
Fiquei me perguntando se havia umcache() operador que poderia armazenar em cache x número de emissões, mas também expirá-las após um intervalo de tempo especificado (por exemplo, 1 minuto). Eu estava procurando por algo como ...
Como compor Observables para evitar os retornos de chamada aninhados e dependentes?
Noeste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , ele dáesta [https://gist.github.com/benjchristensen/4677544](copie / cole o código a seguir) ...
Obter o instantâneo do GoogleMap em segundo plano
Estou tentando obter o instantâneo de um GoogleMap (do MapView) em segundo plano, retorná-lo com um retorno de chamada e mostrá-lo em um ImageView. Enquanto isso, estou tentando tornar a parte do snapshot independente do layout o máximo possível ...
RxAndroid e Retrofit: Não foi possível criar o adaptador de chamada para io.reactivex.Observable <retrofit2.Response <okhttp3.ResponseBody >>
Estou tentando usar rxJava, rxAndroid, Retrofit2 e OkHTTP3 para baixar um arquivo de um ponto de extremidade de URL. Meu código não pode criar o adaptador de chamada para um "Observable <retrofit2.Response <okhttp3.ResponseBody >>". Esses métodos ...
Retrofit 2.0 + RxJava + Corpo JSON de erro
Eu sou muito novo em RxJava e Retrofit e estou tentando escrever minhas chamadas de API com ele. Todas as chamadas de API retornam um corpo JSON por erro, que está no formato geral como, {"errors":[{"code":100, "message":"Login/Password not ...
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 ...
Paginar resultados observáveis sem recursão - RxJava
Eu tenho um problema bastante normal de paginação de API, que você pode lidar com uma recursão simples. Aqui está um exemplo fabricado: public Observable<List<Result>> scan() { return scanPage(Optional.empty(), ImmutableList.of()); } private ...
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 ...