rx-java

0熱

1答えて

私はRxJavaを学び、それは非常に便利だと思っていますが、自分でコードをテストし始めたら、正しく動作しません。私はこのようなコードを書いていますが、何も印刷しません。プログラムは開始直後に停止します。 public static void main(String[] args) { Observable.just(1, 2, 3, 4) .subscribeOn(Sch

0熱

2答えて

RxJava2の再試行オペレータの状態を記憶する方法

私は中断から再開できるネットワーククライアントを持っていますが、再試行があるときに最後のメッセージが必要です。 Kotlinで例： fun requestOrResume(last: Message? = null): Flowable<Message> = Flowable.create({ emitter -> val connection = if (last !=

0熱

1答えて

RxJava2 doOnSubscribeが混乱した順序で実行されるのはなぜですか？

下流上流にサブスクライブする前にdoOnSubscribeを呼び出すために、コード印刷1、RxJava1、2つのコードの印刷の両方において2 Observable.just(1) .doOnSubscribe(d -> System.out.println(1)) .doOnSubscribe(d -> System.out.println(2)) .blocking

0熱

1答えて

Dropwizard @UnitOfWork非同期データベースコール

これは一般的な問題だと思いますが、検索の結果、関連するものは見つけられませんでした。私が抱えている問題は、@UnitOfWorkでリソースメソッドに注釈をつけ、自分のリソースメソッド内に非同期DAO呼び出しを作成するときにNo Hibernate Session bound to thread例外が発生することです。この設計の背後にあるアイデアは、Jerseyリソーススレッドを解放するようにデー

1熱

2答えて

オブザーバブルマップの実行

Map<K, Observable<V>>を実行してMap<K, V>に変換するより洗練された方法がありますか？ @Test public void test() { final ImmutableMap<String, Observable<Integer>> map = ImmutableMap.of( "1", Observable.just(1), "2"

0熱

1答えて

RxJava順序、対象は

を必要と私はこの結果を与える List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5)); Observable.fromIterable(arrayIntegers).map(i -> { Log.d("RxJava", "map i = " + i); return i; })

0熱

2答えて

データ変更時にUIが更新されない

ローカルデータベース（SugarORM）を使用していますが、データベースが変更されたときにUIを更新するためにRXJavaを実装しています。活動が開始されると、それは新しいオブザーバーをサブスクライブ：私のプレゼンタークラスで @Override //This is happening inside doInBackground ! public void onLoading() {

0熱

1答えて

オブザーバブルに再登録する方法

私は4つのタブを持つボトムバーを持っています。各タブはFragmentです。ユーザーが別のFragmentに移動したときにネットワークコールを停止したいので、ObservableコールをCompositeSubscriptionに追加し、onDestroyView()に登録を解除します。次回ユーザーが画面に入ると、すべてのネットワークコールが失敗します（私は退会しているので）ので、再度購読します。

0熱

1答えて

N個のリクエストが完了するまで、Xリクエストを並行して実行します。

指定されたユースケースに対して適切な構成を見つけることができません。私は与えられた入力文字列に対してSingle<String>を生成する関数を持っています。このSingleは、半分ほどかかると予想される複数のタスクの組み合わせですが、これは質問には関係しないと思います。私が達成しようとしている動作は、これらのタスクのうちの5つを、N個のタスクを完了するという目標と並行してアクティブにすること

0熱

1答えて

プログラムが観測可能なタイマーを待つようにする明確な方法はありますか？

私は反応学んでいると私は、このテストクラスで遊んだ： public class ObserverTest{ public static void main(String[] args) { Observable .interval(10, SECONDS) .takeUntil(Observable.timer(30, SECONDS))