rx-android

7熱

4答えて

たちは長いタスク（HTTPリクエスト）を複数回実行しないようにするためにキャッシュ（）演算子を使用することができます完了した場合にのみ、エラーやキャッシュに再試行し、その結果を再利用： Observable apiCall = createApiCallObservable().cache(); // notice the .cache() --------------------------

5熱

1答えて

Rxを使用したボタンクリックのデバウンス

私は単純な「ボタンデバウンサー」を作っています。これは、フィルタリングされたクリックをカウントし、TextViewを通して表示します。私は300ms以下の時間間隔でクリックが無視されるように、急速な/スパムのクリックをフィルタリングしたいと思います。が、私は私の研究を行なったし、つまずい Rxの理論で私が望んでいた正確なことを行う必要があります debounce()素晴らしい.. は..orので

22熱

2答えて

Android RX - Observable.timerは一度だけ起動します

私は定期的に発生する観測可能なものを作成しようとしていますが、わからない何らかの理由で一度だけ発生します。誰でも私が間違っていることを見ることができますか？所定の遅延したがって後に特定のアイテムを発するその観測を作成します。 Observable<Long> observable = Observable.timer(delay, TimeUnit.SECONDS, Schedulers.io

10熱

2答えて

Retrofit + RxJavaがレスポンスのキャッシュに失敗しました。レスポンスヘッダが疑わしいです

Retrofit 1.9.0とOkHtttp 2.5.0でキャッシュを設定しようとしています。ここでは、私は私のRestAdapterためOkHttpClientを提供する方法である： @Provides @Singleton public OkHttpClient provideOkHttpClient() { OkHttpClient okHttpClient = new Ok

5熱

2答えて

RxJava：（遅れて）例外と再試行を公開

私は各30秒後付でREST呼び出し実行され、次の観測があります Subscription subscription = Observable.interval(0, REFRESH_INTERVAL, TimeUnit.SECONDS) .concatMap(new Func1<Long, Observable<Response>>() { @Override