Resultados da pesquisa a pedido "rx-java"
Como processar os primeiros n itens e permanecer um de maneira diferente em um fluxo observável
por exemplo, dado um fluxo de um certo número (m) de números (m1, m2, m3, m4, m5, m6 ...) e aplique uma transformação (2 * i) nos primeiros n itens (n pode ser menor, igual ou maior que m), aplique outra transformação (3 * i) aos itens ...
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 ...
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 ...
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, ...
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()) ...
Qual é a diferença entre Observable, Completable e Single no RxJava
Alguém pode explicar a diferença entre Observável, Completável e Único no RxJava com exemplos claros? Em que cenário usamos um sobre os outros?
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 ...
Rx Java Android: Como converter esse bloco de retorno de chamada em Observer
Estou tentando fazer upload de um arquivo via SDK para Android S3 da Amazon. Eu usei o RX Java um pouco, mas não sei como converter esse método para um método que retorna um Observable, porque quero encadear o resultado desse método para outra ...
Padrão RxJava para solicitar um Observable remoto com um cache temporário
O caso de uso é o seguinte: desejo armazenar em cache temporariamente a última resposta observável cara emitida, mas depois que ela expirar, retorne à fonte cara Observable e faça o cache novamente, etc. Um cenário de cache de rede bastante ...