rx-java2

1熱

1答えて

Flowableがルームでどのように機能するのかを理解できません。私はgetSites()によって返さFlowableオブジェクトにupsert加入者を呼び出したときに常に呼び出されることを期待して、このようなDao方法 @Insert(onConflict = OnConflictStrategy.REPLACE) void upsert(List<Site> sites); @Query

0熱

1答えて

stream1を2回購読する.zip（stream1、stream2、BiFun）を避けるにはどうすればよいですか？

私はいくつかの複雑なデータでアンドロイドのfirebaseを使用しています。私は参照を保存する必要があり、私は私のzip操作、または私はRX全体を処理している方法で問題を取得しています。 Bについての情報を含む新しいA objectを作成し、についての情報を持つようにB objectを更新したいとします。 firebase操作が両方成功しているとき、私はlogcatを経由する場合はSingle<A

2熱

1答えて

SubscibeOnが私の理解あたりとして被験者

には影響しません、 SubscribeOnオペレータは観察可能ソースは、発光を開始するべきスレッドを指定します。チェーンに複数のSubscribeOnがある場合、最初のフローはフロー全体に対しての効果を得ます。 ObserveOnが鎖中にたびObserveOn存在する、任意時点で下流にスレッドを反転するために使用することができ、それは下流ためのスレッドを変更しかし、私はSubjectとI

0熱

1答えて

Flowableとマージ結果の戻り値に基づいてSingleを取得

私はFlowable<List<Entity>>を返すメソッドを呼び出しています。このリストのすべてのエンティティについて、関連するSingle<AnotherEntity>を返すメソッドを呼び出す必要があります。 EntityとAnotherEntityは、1つのオブジェクトにマージされ、すべてがリストに返されます。 return playerRepository.getAllPlayers()

0熱

1答えて

のRx +レトロフィット+ルーム - 私は次のような問題を持っているシングルおよびフロアブル

を組み合わせる：私はレトロフィットを使用してシングル<>要求を取得し、フロアブル<>（ルーム）とそれを組み合わせる必要があります。両方が完了すると、UIにデータが表示されます。そして私はルームから継続的なアップデートを受けたいと思っています。これは一般的な方法であるため、zip演算子を使用しようとしましたが、zipの問題は両方のソースからのデータを待つことです。つまり、 Retrofitから新

1熱

1答えて

Observable not repeating

私はrepeat()に観測を試みていますが、それは複数回実行されていません。 Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> e) throws Exception { // ***

0熱

1答えて

RxJava2の "unsafeSubscribe（）"演算子はどうなりましたか？

https://rxjava-doc.readthedocs.io/en/latest/What%27s-different-in-2.0/には言及されていませんし、コーディング中の提案の中でそれを見ることはできません。私は "safeSubscribe（）"を見ることができます。削除されましたか？ V1で

0熱

1答えて

アンドロイドリポジトリパターンのRxJava

私はRxJavaリポジトリパターンで、Roomをデータベースとして使用し、Retrofitを使用してapiからデータを取得しています。 public interface BcsQuestionService { @GET("get/bTQwGnFsky?indent=2") Observable<List<SubjectModel>> getAllSubject(); }

0熱

1答えて

Observableは次のアクティビティから返された後に購読していません

私はonActivityCreatedの私のフラグメントにCompositeSubscriptionを持っています。 EditTextの文字列を変更すると、mViewModelのコードがObservableを送出します。私はActivityfragmentを起動した場合、私のmViewModelで mSubscription = new CompositeSubscription();