Resultados da pesquisa a pedido "rx-java"
Coletar Observáveis em uma Lista não parece emitir a coleção de uma só vez
Estou usando o RxJava para coletar essencialmente a lista de observáveis emitidos individualmente e combiná-los em uma lista de observáveis (essencialmente o oposto do flatMap). Aqui está o meu código: // myEvent.findMemberships() returns an ...
Implementando um operador tipo torniquete com o RxJava
Preciso de ajuda para implementar um operador semelhante ao torniquete no RxJava (RxScala). Passei bastante tempo pensando sobre isso, mas pareço estar presa. O tipo da função deve ser o seguinte: def turnstile[T](queue: Observable[T], ...
RestAPIs assíncronos com RxJava / Jersey2. Enfiando perguntas?
Estamos no processo de prototipar uma API REST usando programação reativa. Conforme mostrado no diagrama, mantemos três camadas iguais às usadas em nossos projetos de API de sincronização anteriores; http://oi59.tinypic.com/339hhki.jpg ...
Android: sondando um servidor com Retrofit
Estou criando um jogo para 2 jogadores no Android. Como o jogo funciona no sentido horário, o jogador 1 espera até que o jogador 2 faça sua entrada e vice-versa. Eu tenho um servidor da web em que executo uma API com ...
RxJava + retrofit, obtenha uma lista e adicione informações extras para cada item
Estou brincando com o RXJava, adaptado no Android. Estou tentando fazer o seguinte: Preciso pesquisar periodicamente uma chamada que me dê um Observable> (A partir daqui eu poderia fazer isso) Depois de obter essa lista, quero iterar em cada ...
Qual é o objetivo do doOnNext (…) no RxJava
Quando devemos usardoOnNext () [http://reactivex.io/RxJava/javadoc/rx/Observable.html#doOnNext(rx.functions.Action1)] de Observable em vez de apenas onNext ()?
Como compor Observables para evitar os retornos de chamada aninhados e dependentes?
Noeste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , ele dáesta [https://gist.github.com/benjchristensen/4677544](copie / cole o código a seguir) ...
RxJava: diferença entre doOnNext e doOnEach
Em quais casos eu devo usar doOnNext e em quais casos doOnEach? .doOnEach(new Action1<Notification<? super MessageProfile>>() { @Override public void call(Notification<? super MessageProfile> notification) { } }) .doOnNext(new ...
Listas de participação no Android RxJava
Tentando entender tudo o que RxJava. Eu estava fazendo o seguinte exemplo: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return ...
RxJava - Combinando várias / diferentes chamadas de serviço da web
Estou trabalhando com a API do Basecamp para retornar e exibir as listas de tarefas. Aqui está uma amostra do que estou fazendo no momento: bcxClient .fetchToDoLists() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) ...