rx-java

0熱

1答えて

RxJavaを初めて使用しています。私は最初のログインWebサービス（getLoginObservable）を呼び出すシナリオがあり、成功すると、別のWebサービス（getFetchDataObservable）を呼び出してユーザー情報を取得したいと考えています。ログインが成功すると、次のコードが動作します。しかし、私はコードfailureのコード方法を理解することができません。同じくらい私がR

0熱

1答えて

方法（CONCATを使用するRxJava2）

私は現在だけで正常に動作し、このメソッドを持っている： public static Observable<MyCustomObject> run(Service networkService) { return Observable.concat( networkService.getThingOne().map(response -> { Request req

2熱

1答えて

Rxandroid SubscribeOnとObserveOnとの違い

私はRx-javaとRxandroid2を学んでいるだけで、SubscribeOnとObserveOnの主な違いは何ですか？

1熱

1答えて

"else"または "coallesce"のためのrxjavaでのチェイン

私はrxjavaをかなり新しくしているので、これが愚かな質問であれば謝ります。私は2つのMaybesを持っています（AとBと呼んでください）。 Aが成功すると、私は同じ値で成功することができます。 Aエラーの場合は、コンポジットに同じthrowableでエラーが発生するようにします。 Aが値を出さずに完了したら、私はBに委譲したいと思います。これを達成する簡単な方法はありますか？

0熱

2答えて

RxKotlinを使用するときにRxJavaのバージョンを指定する方法は？

GitHubのRxKotlinリポジトリ内のドキュメントに、最新のRxJavaのバージョンnに明示的に依存する方法が指定されていません。私たちは図書館のbuild.gradleファイルが表示されている場合、それはのようになりましたcompile 'io.reactivex.rxjava2:rxjava:2.1.0' を使用しています。しかし、我々は、最新のRxJavaのリリースではなく、ライブラ

2熱

1答えて

rxJava 2スレッドプールとflatMapでの配信不能

subscribeOnとflatMapを組み合わせるとUndeliverableExceptionが表示されます。この最小限の例では、この問題を示しています @Test public void flatMapException() throws ExecutionException, InterruptedException { SettableFuture<Boolean> f =

1熱

1答えて

致命的な例外：RxCachedThreadScheduler-1トリガーを破棄します。どうして？

私はそれがまだThread.sleep(2000)ですが disposable = Observable.create<String>({ subscriber -> try { Thread.sleep(2000) subscriber.onNext("Test") subscriber.onComplete()

0熱

1答えて

RxJava + Kotlinでデータを解析する際に問題が発生する

特定のユーザーのグループを返すJSON応答を解析しようとしています。すべてが正しく返され、私はそれを私のファイル全体に渡って永続化されるべき変更可能なリストに追加しようとします。 private var GROUPS: MutableList<GroupObject> = ArrayList() そして、私のRxJavaコール私はresult.groupsをプリントアウトしても、グループをプリ

0熱

1答えて

RxJavaライフタイムObservable

インタラクタは常時存在するアプリです。そして、そこからいくつかの方法： //Interactor public Observable<Pair<Boolean, String>> getGiftPayPalObservable(Params params) { return session.getTokenObservable().flatMap(token -> {

3熱

1答えて

Flowable/Observable Bufferを無効にする

combineLatest演算子で得られた組み合わせから常に最後の値を取得することに問題があります。私は高周波で2つのホットフロアブル剤（A、B）を生成イベントを持っている（イベントごとに100ミリ秒ごと）：それは仕事だ行うには、ほぼ300ミリ秒を要しcombineLatest、と組み合わせる Flowable<OrderBook> flowA = sourceA.getObservableOr