rx-android

1熱

2答えて

フィルタリングして以下のようにitensを出すことは可能ですか？加入者2回呼び出して私のコード：私が欲しいもの Observable<Map.Entry<String, ArrayList<MockOverview>>> requestEntries = this.requestView.request(request) .map(HashMap::entrySet)

0熱

2答えて

マージを使用してリクエストをキャンセルする方法

実際に私のプロジェクトではRxAndroid、Retrofit2.0、Okhttp 3.2.0を使用しています。ファイルをアップロードするためにObservable.mergeを使用して複数のリクエストを呼び出しています。一意のリクエストをキャンセルするソリューションはありますか？私はsubscription.unsubscribe（）を使用できますが、すべてのタスクをキャンセルします。私は

0熱

1答えて

RxAndroid Observable Populateサブリスト

タイトルが少し曖昧だとわかりましたが、私が持っている問題はかなり複雑です（私にとっては少なくとも）。 APIからリストをロードするObservableがあります。ユーザの応答は、このようになります。 { "status": "Successful", "count": 2, "response": [{ "_id": "abc", "email

0熱

2答えて

並列処理が完了した後のUIのリフレッシュ

私のアプリでRxAndroidを使用しようとしましたが、この問題はしばらく解決していません。各リストオブジェクトをwebservice呼び出しの結果で更新したいと思います。この処理がそれぞれに対して実行されたとき、私はrecyclerviewを更新したいと思います。すべての処理が完了したときに、最後のリストオブジェクトの処理がない起動したときに私の問題がonCompletedさ OLSLog.v

1熱

1答えて

複数のオブザーバーが付いているAndroid Rxlifecycle

私はRxLifecycleを初めて使用しています.RxLifecycleに依存するようにCompositeSubscriptionからAuto unsubscribeを管理しています。質問があります。 7つのネットワークコールがあり、それぞれが個別のSubscriptionを使って追跡されている場合、bindUntilEvent（）を使用してRxFragmentから同じBehaviourSubje

1熱

1答えて

`onCompleted（）`を出すことのパフォーマンスの意味

私はこのようなものを持っています。 Button button = new Button(parent, SWT.PUSH); PublishSubject<Event> subject = PublishSubject.create(); button.addListener(SWT.Selection, e -> subject.onNext(e)); subject.subscribe

1熱

1答えて

RxJava：CountDownLatch never stop

最近、私はRxJavaを学んでいます。 zeroにカウントすると、CountDownLatchは停止します。さて、以下のコードを実行すると、CountDownLaychは決して止まらない！そして、私はJavaプロジェクトと同じコードを実行しようとしました。停止するのは大丈夫です！ Androidのメーカーで @Override protected void onCreate(Bundle sav

7熱

3答えて

PresenterとRxJava、設定変更のための断片を保持

RxJavaを初めて使用し、これをMVPアーキテクチャと共に使用しています。私は、保持されたフラグメントを使用して構成変更を行った際に観測値を保存する例をいくつか見つけました。私が見つけた例は、プレゼンターからではなく、アクティビティーまたはフラグメント上のオブザーバブルを直接処理することです。私はこれをテストしたところでquick example（ReactivexのRxJavaとRxAnd

1熱

1答えて

rxjavaを使用して複数のデータソースを処理する方法は？

これはそうである： Iは、ビジネスロジックのためのインターフェースをフェッチデータを提供するために、ドメイン層を有していて、私は2つのデータソースを有する：ローカルデータベースおよびリモートネットワーク。 DataRepository.getInstance().getUsers(); DataRepositoryで、2つの要因がある：要求するすべてのユーザー：それは次のように動作データが