Resultados da pesquisa a pedido "rx-java"
RxJava - Encadeando solicitações e atualizando a interface do usuário
O problema que estou tendo é esse. Eu preciso executar algumas solicitações para o servidor. Cada próxima solicitação depende do resultado da anterior. Eles ficam assim (abreviados): Observable<FileUploadResponse> obsFile = ...
Kotlin e RxJava - Por que meu Single.zip () não está compilando?
Estou ficando um pouco louco aqui. Estou tentando criar umObservable<BigDecimal> função de extensão (no RxJava 2.x) para emitir a média das emissões, mas estou recebendo um erro de compilação com oSingle.zip() função. Alguém tem alguma idéia do ...
As funções onNext e onComplete do meu assinante não são executadas quando eu chamo onNext na minha classe FlowableOnSubscribe
Em um projeto Android que usa RxJava 2, crio umFlowable assim noonCreate da minha atividade inicial: Flowable.create(new MyFlowableOnSubscribe1(), BackpressureStrategy.BUFFER) .doOnComplete(new MyAction()) ...
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 ...
Rx 2 Android, qual é o melhor Single ou Observable para chamadas de API?
Quando usamos o retrofit2 para fazer chamadas de descanso da API com o Rx, qual é a melhor abordagem a ser usada, única ou observável? public interface ApiService{ Single<Data> getDataFromServer(); Observable<Data> getDataFromServer(); }
Como resolver arquivos duplicados copiados no APK META-INF / rxjava.properties
Estou usando o rxjava e o rxvolley no meu aplicativo para Android. Quando tento executá-lo, recebo este erro Execution failed for task ':testapp:transformResourcesWithMergeJavaResForDebug'. > ...
Como assinar vários assinantes do Observable ou Flowable?
No exemplo Hello World, há um assinante public static void main(String[] args) { Flowable.just("Hello world").subscribe(System.out::println); }Como fazer dois ou mais?
Retrofit e RxJava: como combinar duas solicitações e obter acesso aos dois resultados?
Preciso fazer duas solicitações de serviços e combinar os resultados: ServiceA () =>[{"id":1,"name":"title"},{"id":1,"name":"title"}] ServiceB (id) =>{"field":"value","field1":"value"} Atualmente, consegui combinar os resultados, mas preciso ...
Manipular resposta vazia com retrofit e rxjava 2.x
Ao usar o rxjava 1.x, eu costumava retornarObservable<Void> para lidar com a resposta vazia do retrofit: @POST( "login" ) Observable<Void> getToken( @Header( "Authorization" ) String authorization, @Header( "username" ) String username, @Header( ...
Precisamos cancelar a assinatura do observável que termina / com erros?
Quando eu sei que o observável definitivamente estará completo (comcomplete ou umerror notificação)antes meu componente / classe está fora do escopo, ainda preciso cancelar a assinatura dele para evitar vazamentos de memória? Em outras palavras, ...