Estou trabalhando em rede para meu aplicativo. Então eu decidi experimentar o Retrofit da Square . Eu vejo que eles suportam simplesCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); e RxJava's
No RxJava, existem 5 agendadores diferentes para você escolher: imediato () : cria e retorna um agendador que executa o trabalho imediatamente no segmento atual. trampolim () : cria e retorna um agendador que enfileira o trabalho no encadeamento atual a ser executado após a conclusão do...
Gostaria de saber a diferença entre CompletableFuture, Futuree Observable 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--- semelhante a CompletableFutureoutros benefícios (não...
Quando você usa mapvs flatMapno RxJava ? Digamos, por exemplo, que queremos mapear arquivos que contêm JSON em Strings que contêm o JSON-- Usando map, temos que lidar com isso de Exceptionalguma forma. Mas como?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override public...
A definição de switchmap para rxjava doc é bastante vaga e está vinculada à mesma página que o flatmap. Qual é a diferença entre os dois
Os fluxos do Java 8 são semelhantes aos observáveis do RxJava? Definição de fluxo do Java 8: As classes no novo java.util.streampacote fornecem uma API de fluxo para suportar operações de estilo funcional em fluxos de
Eu estive olhando para o novo rx java 2 e não tenho muita certeza de entender a idéia de backpressuremais ... Estou ciente de que temos Observableque não tem backpressuresuporte eFlowable tem. Assim, com base no exemplo, digamos que eu tenho flowablecom interval: Flowable.interval(1,...
Alguém pode explicar a diferença entre Observable, Completable e Single no RxJava com exemplos claros? Em que cenário usamos um sobre os
Estou tentando atualizar para Retrofit 2.0 e adicionar RxJava em meu projeto android. Estou fazendo uma chamada de api e desejo recuperar o código de erro em caso de uma resposta de erro do servidor. Observable<MyResponseObject> apiCall(@Body body); E na chamada
Vou enviar um método get simples para o meu servidor (é o aplicativo Rails) e obter o resultado usando RxJava e Retrofit. O que eu fiz foi: Minha interface: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post") io.reactivex.Observable<Post>...
Estou usando o rxjava em meu aplicativo Android para lidar com solicitações de rede de forma assíncrona. Agora, gostaria de repetir uma solicitação de rede com falha somente após um determinado período de tempo. Existe alguma maneira de usar retry () em um Observable, mas tentar novamente...
TL; DR Como converter Task.whenAll(List<Task>)em RxJava? Meu código existente usa Bolts para criar uma lista de tarefas assíncronas e espera até que todas essas tarefas sejam concluídas antes de executar outras etapas. Basicamente, ele cria um List<Task>e retorna um, Taskque é...
Quais são os benefícios de usar em Schedulers.newThread()relação Schedulers.io()à Retrofitsolicitação de rede. Já vi muitos exemplos que usam io(), mas quero entender por quê. Situação de exemplo: observable.onErrorResumeNext(refreshTokenAndRetry(observable))