rx-java2

1熱

1答えて

RecyclerView.Adapterのために作成されたプレゼンターがあります。プレゼンターは、APIレイヤーを呼び出してローカルデータ値を変更するメソッドを持っています。これは、Rxのチェーンとして実装されています public void doStuff(Object args) { mRemote.doStuff(args) .doOnNext(count -> mL

3熱

3答えて

Retrofit2 + RxJava2 APIコールをテストするには？

rxjava2経由でRetrofit2コールをテストする方法が不思議です。私の改造APIインタフェースは、次のようになります。 public interface LoginApiMapping { @POST("v1/secm/oam/oauth2/token") Observable<Response<RestResponseHolder<LoginResponseModel

1熱

1答えて

どのようにconcatWith以前のObservableの情報をページングに使用する

私はブロック方法がList<UUID> listOf(int page)と呼ばれるとしましょう。私はこのような何かをページ分割したい場合は、1つのアイデアは、このような何かを行うことです。 public Observable<UUID> allOf(int initialPage) { return fromCallable(() -> listOf(initialPage))

1熱

1答えて

RxJava2は分岐ロジックのために結果を失う

私はある種類のResultをサーバから取得しています。私は、観察可能なシーケンスを構築しようとしています： 1.結果が成功したことを確認します（result.success（）） 2.そうであれば、結果から文字列リソースを取得します（result.getResource（））その文字列で観測可能なものを返します。 3.エラーがなければ、エラー処理コードを実行して空の観測を返します。簡単なswit

0熱

1答えて

Observable.fromCallable（）内でのサブスクリプションのクリア処理

長時間実行されているプロセスがObservable.fromCallable()にラップされている状況があります。このプロセスはOkHttpコールで、終了した場合はIOExceptionとなります。監視対象が購読されている場合、ディスポーザブルはCompositeDisposableに格納され、例外は予期したとおりに処理されます。しかし、私のコードではCompositeDisposableがクリア

1熱

1答えて

RxJava2 PublishSubjectサブスクライバがSingleSchedulerを使用して複数のスレッドから呼び出されたときにアイテムの受信に失敗する

次の単体テストで1Stringを別のスレッドから送信しようとしました。私の問題は、このテストがフラップすることです。場合によっては成功することがありますが、時には8または9のアイテムしか受け取られないことがあります。その後、ラッチがタイムアウトするまでテストがハングアップします。 SingleSchedulerを間違った方法で使用していますか？私は別のことを忘れましたか？ val consumer

-1熱

1答えて

rxjsのようなrxjavaと

observable.zip使用するためにはどのようrxjs（配列、機能）などのrxjavaで（配列、機能）observable.zip使用方法RxJavaで RxJs Observable Zip Array of Observables

-1熱

1答えて

Rxjava 2 Maybe.toSingleエラー

なぜmaybe.toSingle（）にエラーがありませんか？私はdoOnErrorを処理しようとしましたが、動作しません！ Single<Integer> singleOdd = Single.just(1); Single<Integer> singleEven = Single.just(2); Single.concat(singleOdd.filter(intege

0熱

1答えて

私は条件付きでObservableとSingleをマージできますか？

私はRxJavaの新人です。私は次のことをどうやってどうやって頭を悩ましていますか？私は最終的に私の加入者を経由してインスタンスを消費するタイプである私にSingle<Foo>を返すネットワーク要求を、呼び出すためにレトロフィットを使用していは Foo内部プロパティを持っている（それSingleFooSubscriberが呼び出します） itemsと入力します。List<String>と入力しま