rx-java

1熱

1答えて

なぜオブジェクトを注入し、io（）スレッドでapi呼び出しを行うと、Fragmentを開くのが遅くなるのですか？

VacationFragmentのonAttach（）では、VacationViewModel - > VacationRepository、からfeaturedDays（）を呼び出しています。VacationFragmentにナビゲートするビューをクリックしたときに気付いたことは、遅延で開きます。数ミリ秒待っていますそれは、VacationFragmentを開きます。と私はvacationV

0熱

1答えて

RxJava 2 flatMapCompletableで観測できません

私はアイテムを放出し、それらをサーバにアップロードするオブザーバブルを持っています。ここではコードです： repository .getItems() .doOnComplete(() -> Log.d(TAG, "No items left.")) .flatMapCompletable(item -> repository

0熱

1答えて

春5原子炉 - 発光項目ごとに1秒

私は Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) として毎秒値を放出しようとしていますが、それは1秒の遅延を開始すると、一度にすべてを放出しています。どのように各要素の放射を遅延させることができますか？

1熱

1答えて

UIスレッドで監視可能な状態になっています

新しいスレッドでRxJava監視オブジェクトを実行する際に問題が発生しています。 Scheduler.io()でジップDBクエリを実行しようとしていますが、UIスレッドは関係なくブロックします。理由は分かりません。 DB用コード： public Observable<List<T>> searchModelsInView(View view, final Collection<String> s

1熱

2答えて

RxJavaでアンドロイドでクリーンなMVPを使用する：UIスレッドを見ながら、どのようにアンドロイドの知識がなくても、プレゼンターにはどのようにしておくことができますか？プラグインとしてアンドロイドフレームワークを扱い、プレゼンター層に任意のアンドロイド意識の依存関係を漏れないように助言されたMVPパターンをAndroid上で「クリーン」アーキテクチャを実装するための努力において

。しかし public interface SearchPresenter { interface ViewLayer { void updateResults(List<SearchResult> searchResults) } void bind(ViewLayer viewLayer); void unbind(); } publi

1熱

1答えて

別のスレッドでHashMapの値の変更を聴いて、Flowableにする方法はありますか？

私は変化に耳を傾け、いくつかのアクションを作りたいと私は別のスレッドでそれをしたい項目の地図を持っていますが、マップが変更されたが、私はそれを聞くことができは val removedItemList: HashMap<Int,Item> = HashMap() Flowable.fromArray(removedShoppingList.values).subscribeOn(Schedul

0熱

1答えて

RxJava 2無限観測可能完全連鎖

私は観測可能な連鎖があり、その上に無限観測可能で、無限観測後には無限観測可能です。このように： repo.infinitGetItems() .switchMap(items -> Observable .just(items) .flatMap(items -> repo.nonInfinitObs(items))); repo.non

2熱

1答えて

Rx Observableトランザクション内でRealmコールを使用する際に、Realm Threadingの問題を防止するにはどうすればよいですか？

これは、受信トランザクションを RealmHelperRepo呼ばれるビューモデルであり、これはレルム呼び出しが行われRealmRepoクラスである @PerActivity public class RoleSelectionViewModel extends BaseViewModel<RoleSelectionMvvm.View> implements RoleSelectionMvvm.

1熱

2答えて

RxJava：startWith（）デフォルトのemitを追加する方法parent observableが放出するたびに？いくつかのオブジェクトを生成し、私の観察可能なパターンを、持ってしようとしている

イムは、それが理にかなっている場合 public Observable<BookRenderingEvent> extractAndRenderObservable(String epubPath) { return extractObservable(epubPath) .flatMapObservable(extractedEpub -> renderObserva