Resultados da pesquisa a pedido "rx-java"
Observável vs Flowable rxJava2
Eu estive olhando para o novo rx java 2 e não tenho certeza se entendi a ideia debackpressure não mais... Estou ciente de que temosObservable que não tembackpressure suporte eFlowable isso tem. Então, com base no exemplo, digamos que eu ...
Kotlin: O que significa "return @" significa?
Estou usando o RxJava em um dos meus projetos, converti uma das minhas aulas para o Kotlin usando o plug-in Android Studio e em um dos mapasflatMap lambda (Func1 em java), retornos intermediários são parecidos com os seguintes@Func1. Eu não ...
Retrofit chamada API recebe "HTTP FAILED: java.io.IOException: Canceled"
Não consigo descobrir por que isso está acontecendo. Nenhum dos retornos de chamada rx (onCompleted (), onError (), onNext ()) não é acionado pela minha chamada. A única coisa que recebo é esta saída okhttp: D/OkHttp: --> ...
Manipulando null em RxJava2
Com o próximoLiberação RxJava2 [https://github.com/ReactiveX/RxJava/tree/2.x]uma das mudanças importantes é quenull não é mais aceito como um elemento de fluxo, ou seja, o código a seguir lançará uma exceção:Observable.just(null) Sinceramente, ...
RxJava + Retrofit -> BaseObservable para chamadas de API para manipulação de resposta centralizada
Eu sou novo no RxJava, então, por favor, perdoe-me se isso parecer muito novo :-). A partir de agora, tenho um CallbackClass abstrato que implementa o Retofit Callback. Lá, pego os métodos "onResponse" e "onError" do retorno de chamada e lida ...
Qual é a diferença entre Observable e Flowable no RxJava 2.0?
As interfaces observáveis e fluíveis parecem idênticas. Por que o Flowable foi introduzido no RxJava 2.0? Quando devo preferir usar o Flowable sobre o Observable?
RXJava - torne um observável pausável (com buffer e janela, por exemplo)
Eu quero criar observáveis que fazem o seguinte: buffer todos os itens, enquanto eles estão em pausaemitem itens imediatamente, enquanto não estão em pausao gatilho de pausa / retomada deve vir de outro observáveldeve ser salvo para ser usado ...
Fazer outra chamada de Retrofit na emissão de Assunto
Eu tenho uma classe a seguir: public class SessionStore { Subject<Session, Session> subject; public SessionStore() { subject = new SerializedSubject<>(BehaviorSubject.create(new Session()); } public void set(Session session) { ...
Como encadear dois Completable em RxJava2
Eu tenho dois Completable. Gostaria de fazer o seguinte cenário: Se o primeiro Completável chegar ao onComplete, continue com o segundo Completável. Os resultados finais seriam concluídos no segundo Completável. É assim que eu faço quando tenho ...