rx-java

6熱

1答えて

Androidでのデバッグ時にRxJavaキャッシュスレッドでInterruptedExceptionが発生する

アプリケーションをデバッグしているときに、RxCachedThreadScheduler-1でInterruptedExceptionが発生することがあります。 Fatal Exception: java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$Conditio

5熱

1答えて

RxAndroidでスケジューリングを使用する

私はRxAndroid observableを使用してオブジェクト（この場合はString）を取得しています。私は私のプレゼンターにサブスクライブし、ビューに結果を投稿 public Observable<String> getRandomString() { return Observable.create(new Observable.OnSubscribe<String>() {

8熱

2答えて

ProguardとRxAndroid V1.1.0

RxAndroid v1.1.0ライブラリで動作するProguardを取得できないようです。以前私はv1.0.1を使用していましたが、これは次のルールでうまくいきました。私は私のコードでRxAndroidを使用するとき -dontwarn rx.internal.util.unsafe.** しかしrxAndroidのV1.1.0にアップグレードしても、それはGitHubののReadMe.t

6熱

1答えて

RxJava observableの時間がかかる場合、どのようにスピナーを表示しますか？

誰かがこれを試してみたような気がしますが、観察可能なものが長くかかると何かをする良い方法が見つけられません。これは私が求めているフローです。 Start a search. If the search takes longer than some time, show a spinner or show progress bar. When finished do subscrip

11熱

2答えて

RxJavaとRetrofit2：NetworkOnMainThreadException

MainThreadでsubscribeOn（）/ observeOn（）を使用しています。 subscribeOn（）に渡すことができるオプションのセットは何ですか？ observeOn（）に渡すことができるオプションのセットは何ですか？ 12-17 21:36:09.154 20550-20550/rx.test D/MainActivity2: [onCreate] 12-17 21:36

5熱

2答えて

rxandroidを使ってGPS位置更新を聞く方法

最近、私は反応型プログラミングを学び始めました。私のアプリケーションでは、データを非同期に処理する多くのケースでrxandroidを使うようになっています。しかし、私はどのようにロケーションリスナーに適用するのか分からない。ユーザーの場所の変更を購読する方法はありますか？私に考えを与えてください。

5熱

1答えて

リアクティブストリームとリアクティブストリームの違いは何ですか？

ReactiveとReactiveStreamの違いを、特にRxJavaのコンテキストで理解しようとしていますか？ Reactive Streamsには、仕様に背圧という概念がいくつかありますが、それは既にrequest(n)インターフェイスでRxJava/Reactiveに存在しています。 ELI5の回答は気にしません。

6熱

2答えて

AndroidObservable.fromBroadcastは現在どこにありますか？

1.0.0より前には、にfromBroadcastメソッドを持つAndroidObservableクラスがあり、これは反応的な方法でブロードキャストに加入するために使用されました。これはGrokking RxJavaで言及されました：私はまた、あなたがBroadcastReceiverように動作しますObservableを作成することができますAndroidObservable.fromBroa

5熱

1答えて

Kotlinの高次関数とシングルメソッドのインタフェースでの動作は？

以前はRxJavaとKotlinを使っていくつかの問題を抱えていました。私はまだ私が困惑しているいくつかの興味深い発見をしました。私はRxJavaクラスも、Observableに拡張メソッドを追加しようとしていたRxJava public interface Func1<T, R> extends Function { R call(T t); } でシンプルなFunc1インタフ

7熱

3答えて

Android RxJava Observableで2つのクエリを順番に実行するにはどうすればよいですか？

私は2つの非同期タスクを実行したい。私はZIPやFlatについて何かを読んだことがありますが、私はそれをよく理解していませんでした。私の目的はローカルSQLiteからデータをロードすることです。終了すると、リモート）。誰かが私にそれを達成する方法を提案できますか？これは私が（単一のタスク）を使用していますRxJava観察可能なスケルトンです： // RxJava Observable