Resultados da pesquisa a pedido "rx-java"
Procurando uma maneira limpa de lidar com erros no RxJava
Estou aprendendo RxJava e vi em muitos lugares que um erro pode ser tratado desta maneira: repository.getById(10).subscribe(new Action1<User>() { @Override public void call(User user) { //Do something } }, new Action1<Throwable>() { ...
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) { ...
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?
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, ...
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?
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 ...
RxBindings para Spinner?
Eu sou novo android e rxjava. Já passei por muitos exemplos em que ouvimos eventos com rxbindings. tal como este RxView.clicks(b).subscribe(new Action1<Void>() { @Override public void call(Void aVoid) { // do some work here } ...
Executar o método nulo em segundo plano
Eu quero executar um método em segundo plano usando rxjava. Eu não ligo para o resultado. void myHeavyMethod() { (...) }Até agora, a única solução que tenho é modificar o tipo de retorno para, por exemplo.boolean. boolean myHeavyMethod() { ...
Operador RxJava que emite se diferente do último
Existe um operador que emita itens se o item a ser emitido não for igual ao último item emitido?
Como fornecer contexto com Dagger2
Estou aprendendo o Android e estou seguindo alguns guias para o Retrofit2 com RxJava e Dagger2. Agora eu quero lidar com nenhum caso de conexão à Internet. Eu encontrei issoresponda [https://stackoverflow.com/a/40667193/5058677], que parece ...