rx-java

    1

    1答えて

    基本的に私は最初にユーザーにログインしなければなりません。もしsucessfullなら、ショップとログアウトを追加する必要があります。 Observable<BaseResponse<String>> loginObs = apiService.Login(merchant); Observable<BaseResponse<Merchant>> addShopObs = apiService.

    0

    1答えて

    ユーザーの選択を停止したときにのみ、ユーザーのクリックをバッファリング/累積する方法を探しています。 私はrxを試しましたが、最適な解決策を見つけることができませんでした。 ありがとうございました。

    1

    1答えて

    私はメインスレッドで実行しているベースRxJava 2 Observableを持っています。私はobserveOnに別のスレッドで計算を実行するように呼びます。次にcountをサブスクライブするためにautoConnectを使用し、別の副作用操作(計算結果を書き出す)を使用しています。この例では、これはSystem.out.printlnと表示されていますが、これはしばらく時間がかかる操作であると

    1

    1答えて

    私は5つの観測を持っているgetObsX()の実装はRxNettyを通じてネットワーク呼び出しを行うことです Observable<String> obs1 = getObs1(); Observable<String> obs2 = getObs2(); Observable<String> obs3 = getObs3(); Observable<String> obs4 = getOb

    0

    1答えて

    数日後、RxJava2とRetrofit2を独立した方法で使用できます。今私は、RxJava2とRetrofit2を使ったクリーンなアーキテクチャの挑戦を実現しようとしています。ローカルマシン上の単純なRESTサービス用にnodejsサーバーを作成しました。 これまでのところ、これはうまくいきましたが、これを行う正しい方法を探しています。私のプレゼンタークラスの : private void in

    0

    3答えて

    QAチームによって実行されるテストの1つは、いくつかのボタンを熱心にタップして、1つのイベントだけが実行されることを確認することです。この動作を保証するためにRxJavaを使用することは可能ですか?私はRxJavaからthis backpressure pageを読むことを試みましたが、私はそれを本当に理解するのが難しいと感じました。また、私はボタンのonClickListenerからイベントをど

    0

    1答えて

    以下のコードは、ネットワーク通話に問題はありません。常に同じ結果を出しています。最初の結果を出して排出を止めたい。私が言うことができるコマンドは、最初に出すだけではありませんか?私はtake(1)を試みたが、何らかの理由で結果のサイズが変わった。 //class variables FeedsModel feedsModelResult; HashMap<Integer, Pr

    0

    1答えて

    私はテストを書くことを学んでいます。 私は最初のテストを書いて、RxJava 2 + Retrofitからエラーが出ました。 ライン上java.lang.ExceptionInInitializerError.subscribeOn(Schedulers.io()) コード: public void search(String query) { getViewState().showPr

    1

    1答えて

    rxjavaとretrofitを使用してPOSTリクエストを作成し、バックエンドサーバに正常にアクセスし、ユーザをログインさせました(私のコンソールに201の応答があります)。しかし、返されたユーザーアクセストークンを取得したいのですが、rxjavaの結果にアクセスしようとすると、渡されたオブジェクトが返されます。 jsonの成功応答を得る方法をどこにも見つけることができません。私はまた、実際には