Resultados da pesquisa a pedido "rx-java"
Quando cancelar a inscrição de uma assinatura
Eu tenho uma pergunta sobre como cancelar a inscrição de um observável. Eu tenho dois códigos e não tenho muita certeza sobre qual é o melhor. Exemplo 1 -> Cancele a inscrição do assinante assim que o fluxo terminar: Subscriber<String> ...
Como um Observable pode ser pausado sem perder os itens emitidos?
eu tenho umObservable que emite tiques a cada segundo: Observable.interval(0, 1, TimeUnit.SECONDS) .take(durationInSeconds + 1)); Gostaria de pausar este Observable para que ele pare de emitir números e retomá-lo sob demanda. Existem algumas ...
Rx: um operador zip que continua depois que um dos fluxos termina?
Estou procurando combinar fluxos (observáveis) que iniciam e terminam de forma assíncrona: -1----1----1----1---|-> -2----2--|-> [ optional_zip(sum) ] -1----3----3----1---|->Para o que eu preciso: Adicionando fluxos de áudio juntos. Eles são ...
RxJava: itens de buffer até que alguma condição seja verdadeira para o item atual
Aqui está um trecho que estou tentando descobrir: class RaceCondition { Subject<Integer, Integer> subject = PublishSubject.create(); public void entryPoint(Integer data) { subject.onNext(data); } public void client() { subject /*some ...
ReactiveX emite valor nulo ou sentinela após o tempo limite
Procurando uma maneira limpa de transformar uma fonteObservable emitir um úniconull (ou valor sentinela) depois de não emitir um item por algum tempo. Por exemplo, se a fonte observável emitir1, 2, 3 então para de emitir por 10 segundos antes de ...
Observável Único com Vários Assinantes
eu tenho umObservable<<List<Foo>> getFoo() criado a partir de um Serviço de Retrofit e depois de chamar o.getFoo() método, preciso compartilhá-lo com vários assinantes. Chamando o.share() método, porém, faz com que a chamada de rede ...
Como lidar com erros de rede no Retrofit 2 com RxJava
Estou usando o Retrofit2 com o RxJava. Então, minha ligação parece algo como subscriptions.add(authenticateUser(mReq, refreshRequest) .observeOn(Schedulers.io()) .subscribeOn(Schedulers.io()) .subscribe(authResponseModel -> { ...
RxJava: como aplicar condicionalmente operadores a um observável sem quebrar a cadeia
Eu tenho uma cadeia de operadores em um observável RxJava. Eu gostaria de poder aplicar um dos dois operadores, dependendo de um valor booleano sem "quebrar a cadeia". Sou relativamente novo em Rx (Java) e sinto que provavelmente há uma ...
Como usar Observable.fromCallable () com uma exceção marcada?
Observable.fromCallable() é ótimo para converter uma única função em um observável. Mas como você lida com exceções verificadas que podem ser lançadas pela função? A maioria dos exemplos que eu vi usa lambdas e "apenas funciona". Mas como ...
Retrofit Android 2 + RxJava: ouça um fluxo interminável
Posso usar o Retrofit + RxJava para ouvir um fluxo interminável? Por exemplo, o fluxo do Twitter. O que eu tenho é isso: public interface MeetupAPI { @GET("http://stream.meetup.com/2/rsvps/") Observable<RSVP> getRSVPs(); } MeetupAPI api = new ...